| 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'} |
|
305
|
7 |
7 |
if (not $predicate or &$predicate($v, $idx++)) |
|
310
|
3 |
0 |
if defined $subscriber->{'next'} |
|
311
|
3 |
0 |
if defined $subscriber->{'complete'} |
|
337
|
5 |
0 |
if defined $subscriber->{'next'} |
|
341
|
0 |
0 |
if defined $subscriber->{'error'} |
|
352
|
6 |
6 |
if (defined $mini_subscription) |
|
365
|
0 |
0 |
if defined $subscriber->{'error'} |
|
368
|
1 |
1 |
if ($has_last_val) |
|
369
|
1 |
0 |
if defined $subscriber->{'next'} |
|
371
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
404
|
3 |
0 |
if exists $subscriber->{'next'} |
|
407
|
4 |
0 |
if not $source_emitted and exists $subscriber->{'next'} |
|
408
|
7 |
0 |
if exists $subscriber->{'complete'} |
|
436
|
1 |
0 |
if defined $subscriber->{'error'} |
|
441
|
763 |
1 |
unless (defined $queue) |
|
451
|
721 |
8 |
if defined $subscriber->{'next'} |
|
453
|
723 |
5 |
if ($completed and not %timers) |
|
454
|
712 |
11 |
if defined $subscriber->{'complete'} |
|
465
|
1 |
756 |
if (not %timers) |
|
466
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
504
|
3 |
0 |
if defined $subscriber->{'next'} |
|
507
|
0 |
0 |
if defined $subscriber->{'error'} |
|
511
|
1 |
2 |
if ($main_finished and not %mini_subscriptions) |
|
512
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
529
|
0 |
0 |
if defined $subscriber->{'error'} |
|
533
|
0 |
1 |
if (not %mini_subscriptions) |
|
534
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
566
|
3 |
12 |
if ($key_selector) { } |
|
568
|
0 |
3 |
unless ($ok) |
|
569
|
0 |
0 |
if defined $subscriber->{'error'} |
|
575
|
6 |
9 |
if (not exists $keys_passed{$k}) |
|
577
|
6 |
0 |
if defined $subscriber->{'next'} |
|
608
|
19 |
17 |
if (not $have_prev_value && &$comparison_function($prev_value, $value[0])) |
|
609
|
19 |
0 |
if defined $subscriber->{'next'} |
|
639
|
0 |
2 |
unless $index >= 0 |
|
648
|
1 |
5 |
if ($i++ == $index) |
|
649
|
1 |
0 |
if defined $subscriber->{'next'} |
|
650
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
654
|
1 |
0 |
if ($has_default) { } |
|
655
|
1 |
0 |
if defined $subscriber->{'next'} |
|
656
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
658
|
0 |
0 |
if defined $subscriber->{'error'} |
|
698
|
1 |
7 |
if (not &$predicate($v, $idx++)) |
|
699
|
1 |
0 |
if defined $subscriber->{'next'} |
|
700
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
704
|
1 |
0 |
if defined $subscriber->{'next'} |
|
705
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
737
|
5 |
5 |
if $active_subscription |
|
742
|
14 |
0 |
if defined $subscriber->{'next'} |
|
745
|
0 |
0 |
if defined $subscriber->{'error'} |
|
749
|
0 |
3 |
if $big_completed and defined $subscriber->{'complete'} |
|
755
|
0 |
0 |
if defined $subscriber->{'error'} |
|
759
|
0 |
0 |
if not $active_subscription and defined $subscriber->{'complete'} |
|
806
|
0 |
75 |
if (my $error = $@) { } |
|
809
|
30 |
45 |
if $passes and defined $subscriber->{'next'} |
|
846
|
0 |
2 |
unless $predicate |
|
861
|
0 |
2 |
unless $predicate |
|
877
|
0 |
13 |
unless ($ok) |
|
878
|
0 |
0 |
if defined $subscriber->{'error'} |
|
880
|
1 |
12 |
if ($truth) |
|
881
|
1 |
0 |
if defined $subscriber->{'next'} |
|
882
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
886
|
1 |
0 |
if defined $subscriber->{'next'} |
|
887
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
905
|
2 |
5 |
if defined $condition |
|
959
|
3 |
2 |
if ($predicate) { } |
|
962
|
0 |
3 |
unless ($ok) |
|
963
|
0 |
0 |
if defined $subscriber->{'error'} |
|
966
|
1 |
2 |
if ($passes) |
|
976
|
1 |
2 |
if (not $last_val_obtained) { } |
|
977
|
1 |
0 |
if ($has_default) { } |
|
978
|
1 |
0 |
if defined $subscriber->{'next'} |
|
979
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
984
|
2 |
0 |
if defined $subscriber->{'next'} |
|
985
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
1014
|
0 |
116 |
if (my $error = $@) { } |
|
1015
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1017
|
116 |
0 |
if defined $subscriber->{'next'} |
|
1039
|
1 |
0 |
if defined $subscriber->{'next'} |
|
1066
|
0 |
0 |
if (not $has_curr_max) { } |
|
1071
|
0 |
0 |
if (not $comparer) { } |
|
1072
|
0 |
0 |
if ($v > $curr_max) |
|
1077
|
0 |
0 |
if (&$comparer($v, $curr_max) > 0) |
|
1084
|
0 |
0 |
if ($has_curr_max) |
|
1085
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1087
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
1106
|
38 |
0 |
if defined $subscriber->{'next'} |
|
1109
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1113
|
12 |
3 |
if (@$stored_observables) { } |
|
|
3 |
0 |
elsif ($$big_completed_ref and not %$small_subscriptions) { } |
|
1124
|
3 |
0 |
if defined $subscriber->{'complete'} |
|
1155
|
5 |
25 |
if (not defined $concurrent or keys %small_subscriptions < $concurrent) |
|
1168
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1172
|
0 |
3 |
if not %small_subscriptions and defined $subscriber->{'complete'} |
|
1226
|
0 |
0 |
if (not $has_curr_min) { } |
|
1231
|
0 |
0 |
if (not $comparer) { } |
|
1232
|
0 |
0 |
if ($v < $curr_min) |
|
1237
|
0 |
0 |
if (&$comparer($v, $curr_min) < 0) |
|
1244
|
0 |
0 |
if ($has_curr_min) |
|
1245
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1247
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
1297
|
0 |
0 |
if ($have_prev_value) { } |
|
1298
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1318
|
0 |
1 |
unless @keys |
|
1331
|
0 |
5 |
unless (@value) |
|
1332
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1338
|
4 |
3 |
if ((builtin::reftype($cursor) // '') eq 'HASH' and exists $cursor->{$key}) { } |
|
1341
|
3 |
0 |
if defined $subscriber->{'next'} |
|
1346
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1379
|
1 |
1 |
if $got_first |
|
1387
|
9 |
1 |
if ($got_first) { } |
|
1389
|
9 |
0 |
if defined $subscriber->{'error'} |
|
1396
|
2 |
0 |
if $got_first and defined $subscriber->{'next'} |
|
1397
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
1412
|
0 |
0 |
unless $source->isa("RxPerl::ConnectableObservable") |
|
1419
|
0 |
0 |
if (--$count == 0) |
|
1429
|
0 |
0 |
if ($count_was == 0) { } |
|
1456
|
5 |
1 |
if (--$$count_ref) { } |
|
1461
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
1480
|
0 |
3 |
unless defined $count |
|
1481
|
0 |
3 |
if ($count == 0) |
|
1482
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
1511
|
6 |
1 |
if ($$count_ref--) { } |
|
1516
|
1 |
0 |
if defined $subscriber->{'error'} |
|
1536
|
0 |
2 |
unless defined $count |
|
1570
|
0 |
0 |
if ($has_last_val) |
|
1571
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1576
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1618
|
0 |
0 |
if $has_seed |
|
1626
|
0 |
0 |
if (not $has_seed) { } |
|
1634
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1670
|
1 |
2 |
if (not $predicate) { } |
|
1675
|
0 |
2 |
unless ($ok) |
|
1676
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1679
|
1 |
1 |
if $found |
|
1682
|
0 |
3 |
if @found > 1 and defined $subscriber->{'error'} |
|
1685
|
0 |
2 |
if (not @found) { } |
|
1686
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1688
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1689
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
1713
|
0 |
1 |
if $count <= 0 |
|
1717
|
2 |
3 |
if ($count-- <= 0) |
|
1718
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1747
|
2 |
2 |
if (@skipped > $skip_count) |
|
1749
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1764
|
0 |
6 |
unless defined $notifier |
|
1766
|
0 |
6 |
unless builtin::blessed($notifier) and $notifier->isa("RxPerl::Observable") |
|
1783
|
1 |
0 |
if defined $subscriber->{'error'} |
|
1791
|
11 |
21 |
if defined $subscriber->{'next'} and $notifier_has_emitted |
|
1820
|
3 |
3 |
if ($finished_skipping) { } |
|
1825
|
0 |
3 |
unless ($ok) |
|
1826
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1829
|
1 |
2 |
unless ($satisfies_predicate) |
|
1835
|
4 |
2 |
if $should_display and defined $subscriber->{'next'} |
|
1873
|
6 |
0 |
if defined $subscriber->{'next'} |
|
1876
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1880
|
0 |
0 |
if $chief_is_complete and defined $subscriber->{'complete'} |
|
1893
|
2 |
1 |
if $old_subscription |
|
1897
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1901
|
0 |
1 |
if $sub_is_complete and defined $subscriber->{'complete'} |
|
1928
|
0 |
95 |
unless $count >= 0 |
|
1938
|
1 |
78 |
if ($remaining == 0) |
|
1939
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
1946
|
209 |
6 |
if defined $subscriber->{'next'} |
|
1947
|
58 |
157 |
if --$remaining == 0 and defined $subscriber->{'complete'} |
|
1975
|
2 |
5 |
if (@last_values > $count) |
|
1981
|
5 |
0 |
if defined $subscriber->{'next'} |
|
1983
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
2005
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
2008
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2034
|
2 |
4 |
unless (do {
local $_ = $value;
&$cond($value, $i++)
}) |
|
2035
|
1 |
1 |
if $include and defined $subscriber->{'next'} |
|
2036
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
2040
|
4 |
0 |
if defined $subscriber->{'next'} |
|
2061
|
0 |
0 |
if (builtin::reftype($args[0]) // "") eq "HASH" |
|
2073
|
0 |
0 |
if defined $tap_subscriber->{$key} |
|
2074
|
0 |
0 |
if defined $subscriber->{$key} |
|
2099
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2111
|
0 |
0 |
if (not $mini_subscription) |
|
2112
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2150
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2153
|
0 |
0 |
if ($is_empty) { } |
|
2154
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2156
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
2198
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2207
|
0 |
0 |
if defined $subject->{'next'} |
|
2208
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2211
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2214
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
2250
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2251
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
2304
|
4 |
1 |
if (not %didnt_emit) |
|
2305
|
4 |
0 |
if defined $subscriber->{'next'} |
|
2331
|
3 |
17 |
unless defined $x |
|
2332
|
2 |
15 |
unless defined $y |
|
2333
|
1 |
14 |
unless ref $x eq ref $y |
|
2334
|
1 |
13 |
length ref $x ? : |