line |
true |
false |
branch |
63
|
12 |
2 |
if (not %didnt_emit) |
64
|
12 |
0 |
if defined $subscriber->{'next'} |
70
|
2 |
2 |
if ($num_active == 0) |
71
|
2 |
0 |
if defined $subscriber->{'complete'} |
85
|
5 |
71 |
unless (@$sources) |
86
|
5 |
0 |
if defined $subscriber->{'complete'} |
139
|
9 |
0 |
if defined $subscriber->{'complete'} |
151
|
0 |
4 |
unless $arg_is_array or $arg_is_hash |
154
|
2 |
2 |
if ($arg_is_array) |
166
|
2 |
2 |
if $arg_is_array |
172
|
0 |
4 |
unless (@keys) |
173
|
0 |
0 |
if defined $subscriber->{'complete'} |
189
|
9 |
2 |
if (exists $last_values{$key}) { } |
190
|
2 |
7 |
if (keys %last_values == keys %$sources) |
191
|
1 |
1 |
if ($arg_is_array) { } |
194
|
1 |
0 |
if defined $subscriber->{'next'} |
197
|
1 |
0 |
if defined $subscriber->{'next'} |
199
|
2 |
0 |
if defined $subscriber->{'complete'} |
202
|
2 |
0 |
if defined $subscriber->{'complete'} |
215
|
1 |
2 |
if (&blessed($thing) and $thing->isa('RxPerl::Observable')) { } |
|
0 |
2 |
elsif (&blessed($thing) and $thing->isa('Future')) { } |
|
0 |
2 |
elsif (&blessed($thing) and $thing->can('then')) { } |
|
1 |
1 |
elsif (ref $thing eq 'ARRAY' and not &blessed($thing)) { } |
|
1 |
0 |
elsif (defined $thing and not length ref $thing) { } |
224
|
0 |
0 |
if defined $subscriber->{'next'} |
225
|
0 |
0 |
if defined $subscriber->{'complete'} |
229
|
0 |
0 |
if defined $subscriber->{'error'} |
233
|
0 |
0 |
if ($thing->is_cancelled) |
234
|
0 |
0 |
if defined $subscriber->{'complete'} |
246
|
0 |
0 |
if defined $subscriber->{'next'} |
247
|
0 |
0 |
if defined $subscriber->{'complete'} |
250
|
0 |
0 |
if defined $subscriber->{'error'} |
278
|
0 |
0 |
unless $object->isa("Mojo::EventEmitter") |
287
|
0 |
0 |
if defined $subscriber->{'next'} |
291
|
0 |
0 |
if defined $object |
303
|
0 |
0 |
unless $object->isa("Mojo::EventEmitter") |
312
|
0 |
0 |
if defined $subscriber->{'next'} |
316
|
0 |
0 |
if defined $object |
337
|
0 |
6 |
if $must_finish |
339
|
0 |
6 |
unless ($ok) |
340
|
0 |
0 |
if defined $subscriber->{'error'} |
343
|
1 |
5 |
unless ($cond) |
344
|
1 |
0 |
if defined $subscriber->{'complete'} |
347
|
5 |
0 |
$result_selector ? : |
348
|
0 |
5 |
unless ($ok) |
349
|
0 |
0 |
if defined $subscriber->{'error'} |
352
|
5 |
0 |
if defined $subscriber->{'next'} |
354
|
0 |
5 |
unless ($ok) |
355
|
0 |
0 |
if defined $subscriber->{'error'} |
366
|
1 |
1 |
&$condition() ? : |
380
|
172 |
0 |
if defined $subscriber->{'next'} |
404
|
202 |
0 |
if defined $subscriber->{'complete'} |
416
|
156 |
561 |
if (not --$num_active_subscriptions) |
417
|
156 |
0 |
if defined $subscriber->{'complete'} |
445
|
889 |
0 |
if defined $subscriber->{'next'} |
448
|
765 |
3 |
if defined $subscriber->{'complete'} |
457
|
2 |
8 |
unless (@$sources) |
458
|
2 |
0 |
if defined $subscriber->{'complete'} |
541
|
9 |
0 |
if defined $subscriber->{$type} |
565
|
7 |
0 |
if defined $subscriber->{'next'} |
568
|
1 |
0 |
if defined $subscriber->{'complete'} |
584
|
33 |
0 |
if defined $subscriber->{'error'} |
602
|
17 |
67 |
if defined $subscriber->{'next'} |
603
|
3 |
81 |
if (defined $period) { } |
605
|
14 |
0 |
if defined $subscriber->{'next'} |
608
|
74 |
7 |
if defined $subscriber->{'complete'} |
645
|
17 |
31 |
if (not &first(sub {
not @{$_->{'buffer'};};
}
, @sources_metadata)) |
647
|
17 |
0 |
if defined $subscriber->{'next'} |
648
|
21 |
16 |
if not @{$_->{'buffer'};} |
|
4 |
13 |
if (&first(sub {
$_->{'completed'} if not @{$_->{'buffer'};};
}
, @sources_metadata)) |
649
|
4 |
0 |
if defined $subscriber->{'complete'} |
654
|
0 |
0 |
if defined $subscriber->{'error'} |
658
|
0 |
6 |
if (not @{$sources_metadata[$i]{'buffer'};}) |
659
|
0 |
0 |
if defined $subscriber->{'complete'} |