… | |
… | |
270 | my $src_node = $self->{node}; |
270 | my $src_node = $self->{node}; |
271 | |
271 | |
272 | $hdl->push_write ($self->{s_framing} => $_) |
272 | $hdl->push_write ($self->{s_framing} => $_) |
273 | for @$queue; |
273 | for @$queue; |
274 | |
274 | |
275 | my $rmsg; $rmsg = sub { |
275 | my $rmsg; $rmsg = sub { |
276 | $_[0]->push_read ($r_framing => $rmsg); |
276 | $_[0]->push_read ($r_framing => $rmsg); |
277 | |
277 | |
278 | local $AnyEvent::MP::Base::SRCNODE = $src_node; |
278 | local $AnyEvent::MP::Base::SRCNODE = $src_node; |
279 | AnyEvent::MP::Base::_inject (@{ $_[1] }); |
279 | AnyEvent::MP::Base::_inject (@{ $_[1] }); |
280 | }; |
280 | }; |