| line |
true |
false |
branch |
|
64
|
12 |
2 |
if (not %didnt_emit) |
|
65
|
12 |
0 |
if defined $subscriber->{'next'} |
|
71
|
2 |
2 |
if ($num_active == 0) |
|
72
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
86
|
5 |
82 |
unless (@$sources) |
|
87
|
5 |
0 |
if defined $subscriber->{'complete'} |
|
140
|
9 |
0 |
if defined $subscriber->{'complete'} |
|
152
|
0 |
4 |
unless $arg_is_array or $arg_is_hash |
|
155
|
2 |
2 |
if ($arg_is_array) |
|
167
|
2 |
2 |
if $arg_is_array |
|
173
|
0 |
4 |
unless (@keys) |
|
174
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
190
|
11 |
2 |
if (exists $last_values{$key}) { } |
|
191
|
2 |
9 |
if (keys %last_values == keys %$sources) |
|
192
|
1 |
1 |
if ($arg_is_array) { } |
|
195
|
1 |
0 |
if defined $subscriber->{'next'} |
|
198
|
1 |
0 |
if defined $subscriber->{'next'} |
|
200
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
203
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
216
|
1 |
7 |
if (builtin::blessed($thing) and $thing->isa('RxPerl::Observable')) { } |
|
|
0 |
7 |
elsif (builtin::blessed($thing) and $thing->isa('Future')) { } |
|
|
5 |
2 |
elsif (builtin::blessed($thing) and $thing->can('then')) { } |
|
|
1 |
1 |
elsif (ref $thing eq 'ARRAY' and not builtin::blessed($thing)) { } |
|
|
1 |
0 |
elsif (defined $thing and not length ref $thing) { } |
|
225
|
0 |
0 |
if defined $subscriber->{'next'} |
|
226
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
230
|
0 |
0 |
if defined $subscriber->{'error'} |
|
234
|
0 |
0 |
if ($thing->is_cancelled) |
|
235
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
247
|
5 |
0 |
if defined $subscriber->{'next'} |
|
248
|
4 |
1 |
if defined $subscriber->{'complete'} |
|
251
|
0 |
0 |
if defined $subscriber->{'error'} |
|
279
|
0 |
0 |
unless $object->isa("Mojo::EventEmitter") |
|
288
|
0 |
0 |
if defined $subscriber->{'next'} |
|
292
|
0 |
0 |
if defined $object |
|
304
|
0 |
0 |
unless $object->isa("Mojo::EventEmitter") |
|
313
|
0 |
0 |
if defined $subscriber->{'next'} |
|
317
|
0 |
0 |
if defined $object |
|
338
|
0 |
6 |
if $must_finish |
|
340
|
0 |
6 |
unless ($ok) |
|
341
|
0 |
0 |
if defined $subscriber->{'error'} |
|
344
|
1 |
5 |
unless ($cond) |
|
345
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
348
|
5 |
0 |
$result_selector ? : |
|
349
|
0 |
5 |
unless ($ok) |
|
350
|
0 |
0 |
if defined $subscriber->{'error'} |
|
353
|
5 |
0 |
if defined $subscriber->{'next'} |
|
355
|
0 |
5 |
unless ($ok) |
|
356
|
0 |
0 |
if defined $subscriber->{'error'} |
|
367
|
1 |
1 |
&$condition() ? : |
|
381
|
185 |
0 |
if defined $subscriber->{'next'} |
|
405
|
212 |
0 |
if defined $subscriber->{'complete'} |
|
417
|
165 |
588 |
if (not --$num_active_subscriptions) |
|
418
|
165 |
0 |
if defined $subscriber->{'complete'} |
|
444
|
957 |
0 |
if defined $subscriber->{'next'} |
|
447
|
810 |
4 |
if defined $subscriber->{'complete'} |
|
456
|
2 |
8 |
unless (@$sources) |
|
457
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
540
|
9 |
0 |
if defined $subscriber->{$type} |
|
564
|
7 |
0 |
if defined $subscriber->{'next'} |
|
567
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
579
|
40 |
0 |
if defined $subscriber->{'error'} |
|
597
|
7 |
87 |
if (defined $period) { } |
|
599
|
17 |
0 |
if defined $subscriber->{'next'} |
|
601
|
7 |
0 |
if defined $subscriber->{'next'} |
|
603
|
19 |
68 |
if defined $subscriber->{'next'} |
|
604
|
80 |
7 |
if defined $subscriber->{'complete'} |
|
641
|
17 |
31 |
if (not &first(sub {
not @{$_->{'buffer'};};
}
, @sources_metadata)) |
|
643
|
17 |
0 |
if defined $subscriber->{'next'} |
|
644
|
21 |
16 |
if not @{$_->{'buffer'};} |
|
|
4 |
13 |
if (&first(sub {
$_->{'completed'} if not @{$_->{'buffer'};};
}
, @sources_metadata)) |
|
645
|
4 |
0 |
if defined $subscriber->{'complete'} |
|
650
|
0 |
0 |
if defined $subscriber->{'error'} |
|
654
|
0 |
6 |
if (not @{$sources_metadata[$i]{'buffer'};}) |
|
655
|
0 |
0 |
if defined $subscriber->{'complete'} |