X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?p=scpubgit%2FObject-Remote.git;a=blobdiff_plain;f=lib%2FObject%2FRemote%2FReadChannel.pm;h=f6a7cca65c1dada32a5e1a405d979918151b7035;hp=6bfc3694533508204d7edd70f1a6bd84a73cd72c;hb=b7a853b30e7397854a813f6a5878e50703a20079;hpb=b9baacc29444767f88abdbca93f65c8bd5e5a676 diff --git a/lib/Object/Remote/ReadChannel.pm b/lib/Object/Remote/ReadChannel.pm index 6bfc369..f6a7cca 100644 --- a/lib/Object/Remote/ReadChannel.pm +++ b/lib/Object/Remote/ReadChannel.pm @@ -1,7 +1,7 @@ package Object::Remote::ReadChannel; use CPS::Future; -use Scalar::Util qw(weaken); +use Scalar::Util qw(weaken openhandle); use Object::Remote::Logging qw(:log :dlog); use POSIX; use Moo; @@ -58,11 +58,14 @@ sub DEMOLISH { 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;