| line |
l |
!l&&r |
!l&&!r |
condition |
|
172
|
0 |
0 |
0 |
$self->{'events'} //= do {
$self->ryu->source
} |
|
248
|
0 |
0 |
0 |
delete $args{'uri'} // $self->wss_uri |
|
326
|
0 |
0 |
0 |
$self->{'reconnecting'} ||= $self->reconnect->on_ready(sub {
delete $self->{'reconnecting'};
}
) |
|
331
|
0 |
0 |
0 |
$self->{'connection_watchdog'} ||= do {
$self->add_child(my $timer = "IO::Async::Timer::Countdown"->new("delay", 30, "on_expire", $self->$curry::weak(sub {
my($self) = @_;
$self->trigger_reconnect_if_needed;
}
)));
$timer->start;
$timer
} |
|
365
|
0 |
0 |
0 |
eval {
do {
&Encode::decode_utf8($bytes)
}
} // do {
$Net::Async::Slack::Socket::log->errorf("Invalid UTF8 received from Slack: %v02x", $bytes);
return
} |
|
456
|
0 |
0 |
0 |
$id // ++$self->{'last_id'} |
|
469
|
0 |
0 |
0 |
$self->{'ping_timer'} ||= do {
$self->add_child(my $timer = "IO::Async::Timer::Countdown"->new("delay", 10, "on_expire", $self->$curry::weak(sub {
(shift())->trigger_ping;
}
)));
$timer
} |
|
493
|
0 |
0 |
0 |
$self->{'event_handling'} //= $self->events->map($self->$curry::weak(sub {
XXX;
eval {
do {
my($self, $ev) = @_;
do {
XXX
}
}
};
XXX;
}
))->ordered_futures("low", 16, "high", 100) |