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
} |