| line |
true |
false |
branch |
|
61
|
12 |
2 |
if (not %didnt_emit) |
|
62
|
12 |
0 |
if defined $subscriber->{'next'} |
|
68
|
2 |
2 |
if ($num_active == 0) |
|
69
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
83
|
5 |
71 |
unless (@$sources) |
|
84
|
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
|
10 |
2 |
if (exists $last_values{$key}) { } |
|
190
|
2 |
8 |
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
|
177 |
0 |
if defined $subscriber->{'next'} |
|
404
|
203 |
0 |
if defined $subscriber->{'complete'} |
|
416
|
157 |
562 |
if (not --$num_active_subscriptions) |
|
417
|
157 |
0 |
if defined $subscriber->{'complete'} |
|
449
|
894 |
0 |
if defined $subscriber->{'next'} |
|
452
|
768 |
3 |
if defined $subscriber->{'complete'} |
|
461
|
2 |
8 |
unless (@$sources) |
|
462
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
546
|
9 |
0 |
if defined $subscriber->{$type} |
|
570
|
7 |
0 |
if defined $subscriber->{'next'} |
|
573
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
589
|
33 |
0 |
if defined $subscriber->{'error'} |
|
607
|
17 |
67 |
if defined $subscriber->{'next'} |
|
608
|
3 |
81 |
if (defined $period) { } |
|
610
|
14 |
0 |
if defined $subscriber->{'next'} |
|
613
|
74 |
7 |
if defined $subscriber->{'complete'} |
|
650
|
17 |
31 |
if (not &first(sub {
not @{$_->{'buffer'};};
}
, @sources_metadata)) |
|
652
|
17 |
0 |
if defined $subscriber->{'next'} |
|
653
|
21 |
16 |
if not @{$_->{'buffer'};} |
|
|
4 |
13 |
if (&first(sub {
$_->{'completed'} if not @{$_->{'buffer'};};
}
, @sources_metadata)) |
|
654
|
4 |
0 |
if defined $subscriber->{'complete'} |
|
659
|
0 |
0 |
if defined $subscriber->{'error'} |
|
663
|
0 |
6 |
if (not @{$sources_metadata[$i]{'buffer'};}) |
|
664
|
0 |
0 |
if defined $subscriber->{'complete'} |