line |
l |
!l&&r |
!l&&!r |
condition |
142
|
145 |
8 |
0 |
$DEFAULT_CODEC ||= do {
my $HAVE_SEREAL = defined eval {
do {
require Sereal::Encoder;
require Sereal::Decoder
}
};
$HAVE_SEREAL ? "Sereal" : "Storable"
} |
174
|
148 |
0 |
0 |
$self->can("_make_codec_$codec") || croak("Unrecognised codec name '${codec}'") |
203
|
87 |
26 |
0 |
$encoder ||= "Sereal::Encoder"->new |
204
|
41 |
69 |
0 |
$decoder ||= "Sereal::Decoder"->new |
227
|
13 |
8 |
0 |
$SENDMETHODS{$mode} ||= $self->can("_send_$mode") |
290
|
86 |
6 |
0 |
ref $self ? $self->{'encode'} : $default_encode ||= do {
($self->can("_make_codec_" . _default_codec())->())[0]
} |
343
|
105 |
10 |
0 |
$RECVMETHODS{$mode} ||= $self->can("_recv_$mode") |
365
|
175 |
7 |
0 |
$CLOSEMETHODS{$mode} ||= $self->can("_close_$mode") |
447
|
83 |
128 |
0 |
$self->{'stream'} ||= do {
$self->{'on_result_queue'} = [];
my $stream = "IO::Async::Stream"->new("read_handle", $self->{'read_handle'}, "write_handle", $self->{'write_handle'}, "autoflush", 1, "on_read", $self->_capture_weakself("_on_stream_read"));
$self->add_child($stream);
$stream
} |