use Tak::Request;
use Scalar::Util qw(weaken);
+use Log::Contextual qw(:log);
use Moo;
with 'Tak::Role::Service';
Tak->loop->watch_io(
handle => $channel->read_fh,
on_read_ready => sub {
- if (my $message = $channel->read_message) {
- $self->receive(@$message);
- }
+ $channel->read_messages(sub { $self->receive(@_) });
}
);
}