| line |
true |
false |
branch |
|
49
|
4 |
1 |
if defined $subscriber->{'next'} |
|
52
|
1 |
0 |
if defined $subscriber->{'error'} |
|
57
|
1 |
4 |
if ($main_is_complete) |
|
58
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
68
|
6 |
5 |
if (not defined $mini_subscription) |
|
76
|
1 |
0 |
if defined $subscriber->{'error'} |
|
80
|
0 |
1 |
if (not defined $mini_subscription) |
|
81
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
116
|
0 |
0 |
if defined $subscriber->{'error'} |
|
119
|
2 |
0 |
if @buffer and defined $subscriber->{'next'} |
|
121
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
127
|
5 |
0 |
if defined $subscriber->{'next'} |
|
131
|
0 |
0 |
if defined $subscriber->{'error'} |
|
161
|
13 |
5 |
if ($count++ % $start_buffer_every == 0) |
|
170
|
10 |
15 |
if (@$buffer == $buffer_size) |
|
171
|
10 |
0 |
if defined $subscriber->{'next'} |
|
179
|
3 |
0 |
if (defined $subscriber->{'next'}) |
|
183
|
3 |
0 |
if defined $subscriber->{'complete'} |
|
204
|
0 |
0 |
if (@_ == 4) { } |
|
208
|
0 |
0 |
if (my $e = $@) |
|
209
|
0 |
0 |
if defined $subscriber->{'error'} |
|
306
|
7 |
7 |
if (not $predicate or &$predicate($v, $idx++)) |
|
311
|
3 |
0 |
if defined $subscriber->{'next'} |
|
312
|
3 |
0 |
if defined $subscriber->{'complete'} |
|
338
|
5 |
0 |
if defined $subscriber->{'next'} |
|
342
|
0 |
0 |
if defined $subscriber->{'error'} |
|
353
|
6 |
6 |
if (defined $mini_subscription) |
|
366
|
0 |
0 |
if defined $subscriber->{'error'} |
|
369
|
1 |
1 |
if ($has_last_val) |
|
370
|
1 |
0 |
if defined $subscriber->{'next'} |
|
372
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
405
|
3 |
0 |
if exists $subscriber->{'next'} |
|
408
|
4 |
0 |
if not $source_emitted and exists $subscriber->{'next'} |
|
409
|
7 |
0 |
if exists $subscriber->{'complete'} |
|
437
|
1 |
0 |
if defined $subscriber->{'error'} |
|
442
|
727 |
1 |
unless (defined $queue) |
|
452
|
685 |
8 |
if defined $subscriber->{'next'} |
|
454
|
687 |
5 |
if ($completed and not %timers) |
|
455
|
676 |
11 |
if defined $subscriber->{'complete'} |
|
466
|
1 |
720 |
if (not %timers) |
|
467
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
505
|
3 |
0 |
if defined $subscriber->{'next'} |
|
508
|
0 |
0 |
if defined $subscriber->{'error'} |
|
512
|
1 |
2 |
if ($main_finished and not %mini_subscriptions) |
|
513
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
530
|
0 |
0 |
if defined $subscriber->{'error'} |
|
534
|
0 |
1 |
if (not %mini_subscriptions) |
|
535
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
567
|
3 |
12 |
if ($key_selector) { } |
|
569
|
0 |
3 |
unless ($ok) |
|
570
|
0 |
0 |
if defined $subscriber->{'error'} |
|
576
|
6 |
9 |
if (not exists $keys_passed{$k}) |
|
578
|
6 |
0 |
if defined $subscriber->{'next'} |
|
609
|
15 |
12 |
if (not $have_prev_value && &$comparison_function($prev_value, $value[0])) |
|
610
|
15 |
0 |
if defined $subscriber->{'next'} |
|
640
|
0 |
2 |
unless $index >= 0 |
|
649
|
1 |
5 |
if ($i++ == $index) |
|
650
|
1 |
0 |
if defined $subscriber->{'next'} |
|
651
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
655
|
1 |
0 |
if ($has_default) { } |
|
656
|
1 |
0 |
if defined $subscriber->{'next'} |
|
657
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
659
|
0 |
0 |
if defined $subscriber->{'error'} |
|
699
|
1 |
7 |
if (not &$predicate($v, $idx++)) |
|
700
|
1 |
0 |
if defined $subscriber->{'next'} |
|
701
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
705
|
1 |
0 |
if defined $subscriber->{'next'} |
|
706
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
738
|
3 |
3 |
if $active_subscription |
|
743
|
12 |
0 |
if defined $subscriber->{'next'} |
|
746
|
0 |
0 |
if defined $subscriber->{'error'} |
|
750
|
0 |
2 |
if $big_completed and defined $subscriber->{'complete'} |
|
756
|
0 |
0 |
if defined $subscriber->{'error'} |
|
760
|
0 |
0 |
if not $active_subscription and defined $subscriber->{'complete'} |
|
801
|
0 |
75 |
if (my $error = $@) { } |
|
804
|
30 |
45 |
if $passes and defined $subscriber->{'next'} |
|
841
|
0 |
2 |
unless $predicate |
|
856
|
0 |
2 |
unless $predicate |
|
872
|
0 |
13 |
unless ($ok) |
|
873
|
0 |
0 |
if defined $subscriber->{'error'} |
|
875
|
1 |
12 |
if ($truth) |
|
876
|
1 |
0 |
if defined $subscriber->{'next'} |
|
877
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
881
|
1 |
0 |
if defined $subscriber->{'next'} |
|
882
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
900
|
2 |
5 |
if defined $condition |
|
954
|
3 |
2 |
if ($predicate) { } |
|
957
|
0 |
3 |
unless ($ok) |
|
958
|
0 |
0 |
if defined $subscriber->{'error'} |
|
961
|
1 |
2 |
if ($passes) |
|
971
|
1 |
2 |
if (not $last_val_obtained) { } |
|
972
|
1 |
0 |
if ($has_default) { } |
|
973
|
1 |
0 |
if defined $subscriber->{'next'} |
|
974
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
979
|
2 |
0 |
if defined $subscriber->{'next'} |
|
980
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
1009
|
0 |
94 |
if (my $error = $@) { } |
|
1010
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1012
|
94 |
0 |
if defined $subscriber->{'next'} |
|
1034
|
1 |
0 |
if defined $subscriber->{'next'} |
|
1061
|
0 |
0 |
if (not $has_curr_max) { } |
|
1066
|
0 |
0 |
if (not $comparer) { } |
|
1067
|
0 |
0 |
if ($v > $curr_max) |
|
1072
|
0 |
0 |
if (&$comparer($v, $curr_max) > 0) |
|
1079
|
0 |
0 |
if ($has_curr_max) |
|
1080
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1082
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
1101
|
26 |
0 |
if defined $subscriber->{'next'} |
|
1104
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1108
|
8 |
1 |
if (@$stored_observables) { } |
|
|
1 |
0 |
elsif ($$big_completed_ref and not %$small_subscriptions) { } |
|
1119
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
1150
|
3 |
21 |
if (not defined $concurrent or keys %small_subscriptions < $concurrent) |
|
1163
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1167
|
0 |
1 |
if not %small_subscriptions and defined $subscriber->{'complete'} |
|
1221
|
0 |
0 |
if (not $has_curr_min) { } |
|
1226
|
0 |
0 |
if (not $comparer) { } |
|
1227
|
0 |
0 |
if ($v < $curr_min) |
|
1232
|
0 |
0 |
if (&$comparer($v, $curr_min) < 0) |
|
1239
|
0 |
0 |
if ($has_curr_min) |
|
1240
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1242
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
1292
|
0 |
0 |
if ($have_prev_value) { } |
|
1293
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1313
|
0 |
1 |
unless @keys |
|
1326
|
0 |
5 |
unless (@value) |
|
1327
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1333
|
4 |
3 |
if ((&reftype($cursor) // '') eq 'HASH' and exists $cursor->{$key}) { } |
|
1336
|
3 |
0 |
if defined $subscriber->{'next'} |
|
1341
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1374
|
1 |
1 |
if $got_first |
|
1382
|
9 |
1 |
if ($got_first) { } |
|
1384
|
9 |
0 |
if defined $subscriber->{'error'} |
|
1391
|
2 |
0 |
if $got_first and defined $subscriber->{'next'} |
|
1392
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
1407
|
0 |
0 |
unless $source->isa("RxPerl::ConnectableObservable") |
|
1414
|
0 |
0 |
if (--$count == 0) |
|
1424
|
0 |
0 |
if ($count_was == 0) { } |
|
1451
|
5 |
1 |
if (--$$count_ref) { } |
|
1456
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
1475
|
0 |
3 |
unless defined $count |
|
1476
|
0 |
3 |
if ($count == 0) |
|
1477
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
1506
|
6 |
1 |
if ($$count_ref--) { } |
|
1511
|
1 |
0 |
if defined $subscriber->{'error'} |
|
1531
|
0 |
2 |
unless defined $count |
|
1565
|
0 |
0 |
if ($has_last_val) |
|
1566
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1571
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1613
|
0 |
0 |
if $has_seed |
|
1621
|
0 |
0 |
if (not $has_seed) { } |
|
1629
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1665
|
1 |
2 |
if (not $predicate) { } |
|
1670
|
0 |
2 |
unless ($ok) |
|
1671
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1674
|
1 |
1 |
if $found |
|
1677
|
0 |
3 |
if @found > 1 and defined $subscriber->{'error'} |
|
1680
|
0 |
2 |
if (not @found) { } |
|
1681
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1683
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1684
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
1708
|
0 |
1 |
if $count <= 0 |
|
1712
|
2 |
3 |
if ($count-- <= 0) |
|
1713
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1742
|
2 |
2 |
if (@skipped > $skip_count) |
|
1744
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1759
|
0 |
6 |
unless defined $notifier |
|
1761
|
0 |
6 |
unless &blessed($notifier) and $notifier->isa("RxPerl::Observable") |
|
1778
|
1 |
0 |
if defined $subscriber->{'error'} |
|
1786
|
11 |
21 |
if defined $subscriber->{'next'} and $notifier_has_emitted |
|
1815
|
3 |
3 |
if ($finished_skipping) { } |
|
1820
|
0 |
3 |
unless ($ok) |
|
1821
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1824
|
1 |
2 |
unless ($satisfies_predicate) |
|
1830
|
4 |
2 |
if $should_display and defined $subscriber->{'next'} |
|
1868
|
6 |
0 |
if defined $subscriber->{'next'} |
|
1871
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1875
|
0 |
0 |
if $chief_is_complete and defined $subscriber->{'complete'} |
|
1888
|
2 |
1 |
if $old_subscription |
|
1892
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1896
|
0 |
1 |
if $sub_is_complete and defined $subscriber->{'complete'} |
|
1923
|
0 |
86 |
unless $count >= 0 |
|
1933
|
1 |
69 |
if ($remaining == 0) |
|
1934
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
1941
|
181 |
6 |
if defined $subscriber->{'next'} |
|
1942
|
49 |
138 |
if --$remaining == 0 and defined $subscriber->{'complete'} |
|
1970
|
2 |
5 |
if (@last_values > $count) |
|
1976
|
5 |
0 |
if defined $subscriber->{'next'} |
|
1978
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
2000
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
2003
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2029
|
2 |
4 |
unless (do {
local $_ = $value;
&$cond($value, $i++)
}) |
|
2030
|
1 |
1 |
if $include and defined $subscriber->{'next'} |
|
2031
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
2035
|
4 |
0 |
if defined $subscriber->{'next'} |
|
2056
|
0 |
0 |
if (&reftype($args[0]) // "") eq "HASH" |
|
2068
|
0 |
0 |
if defined $tap_subscriber->{$key} |
|
2069
|
0 |
0 |
if defined $subscriber->{$key} |
|
2094
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2106
|
0 |
0 |
if (not $mini_subscription) |
|
2107
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2145
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2148
|
0 |
0 |
if ($is_empty) { } |
|
2149
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2151
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
2193
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2202
|
0 |
0 |
if defined $subject->{'next'} |
|
2203
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2206
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2209
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
2245
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2246
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
2299
|
4 |
1 |
if (not %didnt_emit) |
|
2300
|
4 |
0 |
if defined $subscriber->{'next'} |
|
2326
|
3 |
17 |
unless defined $x |
|
2327
|
2 |
15 |
unless defined $y |
|
2328
|
1 |
14 |
unless ref $x eq ref $y |
|
2329
|
1 |
13 |
length ref $x ? : |