blib/lib/RxPerl/Operators/Pipeable.pm | |||
---|---|---|---|
Criterion | Covered | Total | % |
condition | 48 | 88 | 54.5 |
line | l | !l | condition |
---|---|---|---|
1035 | 0 | 2 | $own_subscriber->{'next'} &&= sub { $subscriber->{'next'}->($mapping_value) if defined $subscriber->{'next'}; } |
1746 | 0 | 1 | $own_subscriber->{'next'} &&= sub { my($v) = @_; push @skipped, $v; if (@skipped > $skip_count) { my $new_v = shift @skipped; $subscriber->{'next'}->($new_v) if defined $subscriber->{'next'}; }; } |
line | !l | l&&!r | l&&r | condition |
---|---|---|---|---|
119 | 0 | 0 | 2 | @buffer and defined $subscriber->{'next'} |
408 | 3 | 0 | 4 | not $source_emitted and exists $subscriber->{'next'} |
454 | 3 | 2 | 687 | $completed and not %timers |
512 | 0 | 2 | 1 | $main_finished and not %mini_subscriptions |
609 | 4 | 11 | 12 | $have_prev_value && &$comparison_function($prev_value, $value[0]) |
750 | 2 | 0 | 0 | $big_completed and defined $subscriber->{'complete'} |
760 | 0 | 0 | 0 | not $active_subscription and defined $subscriber->{'complete'} |
804 | 45 | 0 | 30 | $passes and defined $subscriber->{'next'} |
1108 | 0 | 0 | 1 | $$big_completed_ref and not %$small_subscriptions |
1167 | 1 | 0 | 0 | not %small_subscriptions and defined $subscriber->{'complete'} |
1333 | 2 | 1 | 4 | (&reftype($cursor) // "") eq "HASH" and exists $cursor->{$key} |
1391 | 0 | 0 | 2 | $got_first and defined $subscriber->{'next'} |
1677 | 3 | 0 | 0 | @found > 1 and defined $subscriber->{'error'} |
1761 | 0 | 0 | 6 | &blessed($notifier) and $notifier->isa("RxPerl::Observable") |
1786 | 0 | 21 | 11 | defined $subscriber->{'next'} and $notifier_has_emitted |
1830 | 2 | 0 | 4 | $should_display and defined $subscriber->{'next'} |
1875 | 0 | 0 | 0 | $chief_is_complete and defined $subscriber->{'complete'} |
1896 | 1 | 0 | 0 | $sub_is_complete and defined $subscriber->{'complete'} |
1942 | 136 | 2 | 49 | --$remaining == 0 and defined $subscriber->{'complete'} |
2030 | 1 | 0 | 1 | $include and defined $subscriber->{'next'} |
line | l | !l | condition |
---|---|---|---|
593 | 2 | 2 | $comparison_function //= \&RxPerl::Operators::Pipeable::_eqq |
824 | 4 | 4 | $subscriber->{'_subscription'}{'_finalize_cbs'} //= [] |
1333 | 5 | 2 | &reftype($cursor) // "" |
1716 | 0 | 1 | $own_subscriber //= {%$subscriber, "next", sub { if ($count-- <= 0) { $subscriber->{'next'}->(@_) if defined $subscriber->{'next'}; }; } } |
2056 | 0 | 0 | &reftype($args[0]) // "" |
2058 | 0 | 0 | $tap_subscriber //= {map({$_, shift @args;} "next", "error", "complete")} |
line | l | !l&&r | !l&&!r | condition |
---|---|---|---|---|
146 | 1 | 2 | 0 | $start_buffer_every //= $buffer_size |
306 | 0 | 7 | 7 | not $predicate or &$predicate($v, $idx++) |
1150 | 0 | 3 | 21 | not defined $concurrent or keys %small_subscriptions < $concurrent |
1384 | 9 | 0 | 0 | $ok or $subscriber->{'error'}->($@) |