| line |
true |
false |
branch |
|
16
|
1 |
49 |
unless $scope and ref $scope eq "HASH" |
|
18
|
1 |
48 |
unless $receive and ref $receive eq "CODE" |
|
20
|
1 |
47 |
unless $send and ref $send eq "CODE" |
|
23
|
1 |
46 |
unless ($scope->{'type'} // "") eq "sse" |
|
28
|
0 |
46 |
if $scope->{'pagi.sse'} |
|
56
|
0 |
0 |
unless defined $str |
|
65
|
0 |
0 |
unless defined $str |
|
66
|
0 |
0 |
$strict ? : |
|
77
|
0 |
0 |
if %opts |
|
79
|
0 |
0 |
$strict ? : |
|
|
0 |
0 |
$raw ? : |
|
80
|
0 |
0 |
if $self->{'scope'}{$cache_key} |
|
86
|
0 |
0 |
unless length $part |
|
96
|
0 |
0 |
$raw ? : |
|
97
|
0 |
0 |
$raw ? : |
|
191
|
2 |
22 |
if $self->is_started or $self->is_closed |
|
197
|
1 |
21 |
if exists $opts{'headers'} |
|
225
|
5 |
9 |
if (lc $pair->[0] eq $name) |
|
235
|
0 |
1 |
if $self->{'scope'}{'pagi.request.headers'} |
|
262
|
1 |
8 |
if $self->is_closed |
|
265
|
1 |
7 |
unless $self->is_started |
|
279
|
0 |
2 |
if $self->is_closed |
|
281
|
0 |
2 |
unless $self->is_started |
|
297
|
0 |
10 |
if $self->is_closed |
|
298
|
0 |
10 |
unless exists $opts{'data'} |
|
300
|
2 |
8 |
unless $self->is_started |
|
304
|
8 |
2 |
if (ref $data) |
|
313
|
8 |
2 |
if defined $opts{'event'} |
|
314
|
8 |
2 |
if defined $opts{'id'} |
|
315
|
2 |
8 |
if defined $opts{'retry'} |
|
325
|
1 |
2 |
if $self->is_closed |
|
328
|
0 |
2 |
unless $self->is_started |
|
334
|
1 |
1 |
if ($@) |
|
343
|
0 |
1 |
if $self->is_closed |
|
346
|
0 |
1 |
unless $self->is_started |
|
353
|
0 |
1 |
if ($@) |
|
364
|
0 |
0 |
if $self->is_closed |
|
366
|
0 |
0 |
unless $self->is_started |
|
378
|
0 |
0 |
if $self->is_closed |
|
381
|
0 |
0 |
unless $self->is_started |
|
387
|
0 |
0 |
if ($@) |
|
396
|
0 |
1 |
if $self->is_closed |
|
399
|
0 |
1 |
unless $self->is_started |
|
402
|
0 |
1 |
if (ref $data) |
|
410
|
1 |
0 |
if defined $opts{'event'} |
|
411
|
0 |
1 |
if defined $opts{'id'} |
|
412
|
0 |
1 |
if defined $opts{'retry'} |
|
416
|
0 |
1 |
if ($@) |
|
442
|
0 |
6 |
if $self->{'_close_callbacks_ran'} |
|
450
|
1 |
7 |
if (builtin::blessed($r) and $r->isa("Future")) |
|
454
|
0 |
8 |
if ($@) |
|
464
|
0 |
1 |
if $self->is_closed |
|
476
|
0 |
5 |
unless $self->is_started |
|
482
|
5 |
0 |
if ($type eq "sse.disconnect") |
|
497
|
0 |
3 |
unless $self->is_started |
|
502
|
2 |
1 |
if (ref $source eq 'ARRAY') { } |
|
|
1 |
0 |
elsif (ref $source eq 'CODE') { } |
|
504
|
0 |
5 |
if $self->is_closed |
|
509
|
2 |
3 |
if (ref $result eq "HASH") |
|
518
|
1 |
3 |
unless defined $item |
|
522
|
0 |
3 |
if (ref $result eq "HASH") |
|
539
|
0 |
1 |
unless defined $interval and $interval > 0 |
|
540
|
0 |
1 |
unless ref $callback eq "CODE" |
|
543
|
0 |
1 |
unless eval {
do {
require Future::IO;
1
}
} |
|
549
|
1 |
0 |
unless $Future::IO::IMPL |
|
553
|
0 |
0 |
unless $self->is_started |
|
561
|
0 |
0 |
unless ($ok) |
|
574
|
0 |
0 |
if ($self->is_closed) |
|
575
|
0 |
0 |
if $sleep_future->can("cancel") and not $sleep_future->is_ready |
|
581
|
0 |
0 |
if $disconnect_future->can("cancel") and not $disconnect_future->is_ready |
|
598
|
0 |
0 |
unless $event |
|
601
|
0 |
0 |
if ($type eq "sse.disconnect") |
|
602
|
0 |
0 |
if ($weak_self) |