| line |
true |
false |
branch |
|
63
|
3 |
0 |
if ($self->auto_anchor) |
|
66
|
2 |
1 |
unless (defined $$args{'anchors'}) |
|
71
|
0 |
2 |
if (ref $a eq 'IO::Storm::Tuple') |
|
77
|
1 |
2 |
if (defined $$args{'stream'}) |
|
81
|
0 |
3 |
if (defined $$args{'direct_task'}) |
|
89
|
0 |
3 |
if (defined $$msg{'task'}) { } |
|
100
|
1 |
0 |
if (ref $tuple eq 'IO::Storm::Tuple') { } |
|
112
|
1 |
0 |
if (ref $tuple eq 'IO::Storm::Tuple') { } |
|
134
|
0 |
0 |
if ($$tup{'task'} == -1 and $$tup{'stream'} eq '__heartbeat') { } |
|
139
|
0 |
0 |
if ($self->auto_ack) |
|
152
|
0 |
0 |
if (scalar @{$self->_current_tups;} == 1) |
|
154
|
0 |
0 |
if ($self->auto_fail) |