package Object::Remote::ReadChannel;
-use CPS::Future;
use Scalar::Util qw(weaken openhandle);
-use Object::Remote::Logging qw(:log :dlog);
+use Object::Remote::Logging qw(:log :dlog router );
use Moo;
+BEGIN { router()->exclude_forwarding }
+
has fh => (
is => 'ro', required => 1,
trigger => sub {
my ($self, $gd) = @_;
return if $gd;
log_trace { "read channel is being demolished" };
-
+
Object::Remote->current_loop
->unwatch_io(
handle => $self->fh,
on_read_ready => 1
);
-
-
}
1;