| line |
true |
false |
branch |
|
27
|
0 |
0 |
if ($err) |
|
29
|
0 |
0 |
if $err =~ /no message found|10037/ |
|
33
|
0 |
0 |
unless $msg |
|
35
|
0 |
0 |
if EV::Nats::JetStream::msg_is_tombstone($msg) |
|
50
|
0 |
0 |
if $err |
|
61
|
0 |
0 |
if ($cb) { } |
|
66
|
0 |
0 |
if ($timer) |
|
68
|
0 |
0 |
if $derr |
|
69
|
0 |
0 |
if $ack->{'error'} |
|
91
|
0 |
0 |
defined $_[0] ? : |
|
|
0 |
0 |
if $cb |
|
100
|
0 |
0 |
defined $_[0] ? : |
|
|
0 |
0 |
if $cb |
|
111
|
0 |
0 |
if $err |
|
131
|
0 |
0 |
if ($headers and $headers =~ /KV-Operation:\s*(\S+)/i) |
|
149
|
0 |
0 |
$opts->{'max_bytes'} ? : |
|
|
0 |
0 |
$opts->{'max_age'} ? : |
|
|
0 |
0 |
$opts->{'replicas'} ? : |
|
167
|
0 |
0 |
if $err |