blib/lib/Mojo/WebSocketProxy/Backend/JobAsync.pm | |||
---|---|---|---|
Criterion | Covered | Total | % |
condition | 7 | 20 | 35.0 |
line | !l | l&&!r | l&&r | condition |
---|---|---|---|---|
135 | 0 | 0 | 2 | $c and $c->tx |
line | l | !l | condition |
---|---|---|---|
114 | 0 | 2 | $req_storage->{'call_params'} ||= {} |
117 | 2 | 0 | delete $req_storage->{'before_get_rpc_response'} || [] |
118 | 2 | 0 | delete $req_storage->{'after_got_rpc_response'} || [] |
119 | 2 | 0 | delete $req_storage->{'before_call'} || [] |
line | l | !l&&r | !l&&!r | condition |
---|---|---|---|---|
92 | 0 | 2 | 0 | $req_storage->{'msg_type'} ||= $req_storage->{'method'} |
97 | 2 | 0 | 0 | $self->{'client'} //= do { $self->{'loop'} //= do { require IO::Async::Loop::Mojo; local $ENV{'IO_ASYNC_LOOP'} = 'IO::Async::Loop::Mojo'; 'IO::Async::Loop'->new }; $self->{'loop'}->add(my $jobman = 'Job::Async'->new); &Math::Random::Secure::srand() if 'Math::Random::Secure'->can('srand'); my $client_job = $jobman->client('redis', $self->{'redis'}); $client_job->start->retain; $client_job } |
99 | 0 | 0 | 0 | $self->{'loop'} //= do { require IO::Async::Loop::Mojo; local $ENV{'IO_ASYNC_LOOP'} = 'IO::Async::Loop::Mojo'; 'IO::Async::Loop'->new } |