line |
true |
false |
branch |
44
|
0 |
0 |
unless (defined $queue) |
52
|
0 |
0 |
if defined $subscriber->{$type} |
80
|
0 |
0 |
if (my $error = $@) { } |
83
|
0 |
0 |
if $passes and defined $subscriber->{'next'} |
106
|
0 |
0 |
if (my $error = $@) { } |
107
|
0 |
0 |
if defined $subscriber->{'error'} |
109
|
0 |
0 |
if defined $subscriber->{'next'} |
131
|
0 |
0 |
if defined $subscriber->{'next'} |
167
|
0 |
0 |
if ($have_prev_value) { } |
168
|
0 |
0 |
if defined $subscriber->{'next'} |
189
|
0 |
0 |
unless $source->isa('Mojo::Rx::ConnectableObservable') |
196
|
0 |
0 |
if (--$count == 0) |
206
|
0 |
0 |
if ($count_was == 0) { } |
235
|
0 |
0 |
if $has_seed |
243
|
0 |
0 |
if (not $has_seed) { } |
251
|
0 |
0 |
if defined $subscriber->{'next'} |
273
|
0 |
0 |
unless $count >= 0 |
283
|
0 |
0 |
if ($remaining == 0) |
284
|
0 |
0 |
if defined $subscriber->{'complete'} |
291
|
0 |
0 |
if defined $subscriber->{'next'} |
292
|
0 |
0 |
if --$remaining == 0 and defined $subscriber->{'complete'} |
314
|
0 |
0 |
if defined $subscriber->{'complete'} |
317
|
0 |
0 |
if defined $subscriber->{'error'} |
338
|
0 |
0 |
if (&reftype($args[0]) // '') eq 'HASH' |
350
|
0 |
0 |
if defined $tap_subscriber->{$key} |
351
|
0 |
0 |
if defined $subscriber->{$key} |