| 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
|
729 |
1 |
unless (defined $queue) |
|
452
|
687 |
8 |
if defined $subscriber->{'next'} |
|
454
|
689 |
5 |
if ($completed and not %timers) |
|
455
|
678 |
11 |
if defined $subscriber->{'complete'} |
|
466
|
1 |
722 |
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 |
|
929
|
5 |
0 |
unless $stop_producing_observables |
|
935
|
5 |
0 |
if exists $observables{$key} and defined $observables{$key}{'next'} |
|
938
|
0 |
0 |
if defined $subscriber->{'error'} |
|
942
|
2 |
0 |
if defined $val->{'complete'} |
|
944
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
1005
|
3 |
2 |
if ($predicate) { } |
|
1008
|
0 |
3 |
unless ($ok) |
|
1009
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1012
|
1 |
2 |
if ($passes) |
|
1022
|
1 |
2 |
if (not $last_val_obtained) { } |
|
1023
|
1 |
0 |
if ($has_default) { } |
|
1024
|
1 |
0 |
if defined $subscriber->{'next'} |
|
1025
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
1030
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1031
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
1060
|
0 |
96 |
if (my $error = $@) { } |
|
1061
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1063
|
96 |
0 |
if defined $subscriber->{'next'} |
|
1085
|
1 |
0 |
if defined $subscriber->{'next'} |
|
1112
|
0 |
0 |
if (not $has_curr_max) { } |
|
1117
|
0 |
0 |
if (not $comparer) { } |
|
1118
|
0 |
0 |
if ($v > $curr_max) |
|
1123
|
0 |
0 |
if (&$comparer($v, $curr_max) > 0) |
|
1130
|
0 |
0 |
if ($has_curr_max) |
|
1131
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1133
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
1152
|
28 |
0 |
if defined $subscriber->{'next'} |
|
1155
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1159
|
8 |
3 |
if (@$stored_observables) { } |
|
|
1 |
4 |
elsif ($$big_completed_ref and not %$small_subscriptions) { } |
|
1170
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
1201
|
5 |
21 |
if (not defined $concurrent or keys %small_subscriptions < $concurrent) |
|
1214
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1218
|
1 |
1 |
if not %small_subscriptions and defined $subscriber->{'complete'} |
|
1272
|
0 |
0 |
if (not $has_curr_min) { } |
|
1277
|
0 |
0 |
if (not $comparer) { } |
|
1278
|
0 |
0 |
if ($v < $curr_min) |
|
1283
|
0 |
0 |
if (&$comparer($v, $curr_min) < 0) |
|
1290
|
0 |
0 |
if ($has_curr_min) |
|
1291
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1293
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
1343
|
0 |
0 |
if ($have_prev_value) { } |
|
1344
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1364
|
0 |
1 |
unless @keys |
|
1377
|
0 |
5 |
unless (@value) |
|
1378
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1384
|
4 |
3 |
if ((&reftype($cursor) // '') eq 'HASH' and exists $cursor->{$key}) { } |
|
1387
|
3 |
0 |
if defined $subscriber->{'next'} |
|
1392
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1425
|
3 |
1 |
if $got_first |
|
1433
|
14 |
1 |
if ($got_first) { } |
|
1435
|
14 |
0 |
if defined $subscriber->{'error'} |
|
1442
|
4 |
0 |
if $got_first and defined $subscriber->{'next'} |
|
1443
|
4 |
0 |
if defined $subscriber->{'complete'} |
|
1458
|
0 |
0 |
unless $source->isa("RxPerl::ConnectableObservable") |
|
1465
|
0 |
0 |
if (--$count == 0) |
|
1475
|
0 |
0 |
if ($count_was == 0) { } |
|
1502
|
5 |
1 |
if (--$$count_ref) { } |
|
1507
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
1526
|
0 |
3 |
unless defined $count |
|
1527
|
0 |
3 |
if ($count == 0) |
|
1528
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
1557
|
6 |
1 |
if ($$count_ref--) { } |
|
1562
|
1 |
0 |
if defined $subscriber->{'error'} |
|
1582
|
0 |
2 |
unless defined $count |
|
1616
|
0 |
0 |
if ($has_last_val) |
|
1617
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1622
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1664
|
0 |
0 |
if $has_seed |
|
1672
|
0 |
0 |
if (not $has_seed) { } |
|
1680
|
0 |
0 |
if defined $subscriber->{'next'} |
|
1716
|
1 |
2 |
if (not $predicate) { } |
|
1721
|
0 |
2 |
unless ($ok) |
|
1722
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1725
|
1 |
1 |
if $found |
|
1728
|
0 |
3 |
if @found > 1 and defined $subscriber->{'error'} |
|
1731
|
0 |
2 |
if (not @found) { } |
|
1732
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1734
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1735
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
1759
|
0 |
1 |
if $count <= 0 |
|
1763
|
2 |
3 |
if ($count-- <= 0) |
|
1764
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1793
|
2 |
2 |
if (@skipped > $skip_count) |
|
1795
|
2 |
0 |
if defined $subscriber->{'next'} |
|
1810
|
0 |
6 |
unless defined $notifier |
|
1812
|
0 |
6 |
unless &blessed($notifier) and $notifier->isa("RxPerl::Observable") |
|
1829
|
1 |
0 |
if defined $subscriber->{'error'} |
|
1837
|
11 |
21 |
if defined $subscriber->{'next'} and $notifier_has_emitted |
|
1866
|
3 |
3 |
if ($finished_skipping) { } |
|
1871
|
0 |
3 |
unless ($ok) |
|
1872
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1875
|
1 |
2 |
unless ($satisfies_predicate) |
|
1881
|
4 |
2 |
if $should_display and defined $subscriber->{'next'} |
|
1919
|
6 |
0 |
if defined $subscriber->{'next'} |
|
1922
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1926
|
0 |
0 |
if $chief_is_complete and defined $subscriber->{'complete'} |
|
1939
|
2 |
1 |
if $old_subscription |
|
1943
|
0 |
0 |
if defined $subscriber->{'error'} |
|
1947
|
0 |
1 |
if $sub_is_complete and defined $subscriber->{'complete'} |
|
1974
|
0 |
87 |
unless $count >= 0 |
|
1984
|
1 |
70 |
if ($remaining == 0) |
|
1985
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
1992
|
186 |
6 |
if defined $subscriber->{'next'} |
|
1993
|
50 |
142 |
if --$remaining == 0 and defined $subscriber->{'complete'} |
|
2021
|
2 |
5 |
if (@last_values > $count) |
|
2027
|
5 |
0 |
if defined $subscriber->{'next'} |
|
2029
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
2051
|
1 |
0 |
if defined $subscriber->{'complete'} |
|
2054
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2080
|
2 |
4 |
unless (do {
local $_ = $value;
&$cond($value, $i++)
}) |
|
2081
|
1 |
1 |
if $include and defined $subscriber->{'next'} |
|
2082
|
2 |
0 |
if defined $subscriber->{'complete'} |
|
2086
|
4 |
0 |
if defined $subscriber->{'next'} |
|
2107
|
0 |
0 |
if (&reftype($args[0]) // "") eq "HASH" |
|
2119
|
0 |
0 |
if defined $tap_subscriber->{$key} |
|
2120
|
0 |
0 |
if defined $subscriber->{$key} |
|
2145
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2157
|
0 |
0 |
if (not $mini_subscription) |
|
2158
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2196
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2199
|
0 |
0 |
if ($is_empty) { } |
|
2200
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2202
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
2244
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2253
|
0 |
0 |
if defined $subject->{'next'} |
|
2254
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2257
|
0 |
0 |
if defined $subscriber->{'error'} |
|
2260
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
2296
|
0 |
0 |
if defined $subscriber->{'next'} |
|
2297
|
0 |
0 |
if defined $subscriber->{'complete'} |
|
2350
|
4 |
1 |
if (not %didnt_emit) |
|
2351
|
4 |
0 |
if defined $subscriber->{'next'} |
|
2377
|
3 |
17 |
unless defined $x |
|
2378
|
2 |
15 |
unless defined $y |
|
2379
|
1 |
14 |
unless ref $x eq ref $y |
|
2380
|
1 |
13 |
length ref $x ? : |