use CPS::Future;
use Scalar::Util qw(weaken openhandle);
use Object::Remote::Logging qw(:log :dlog);
-use POSIX;
use Moo;
has fh => (
while (my $cb = $self->on_line_call and $$rb =~ s/^(.*)\n//) {
$cb->(my $line = $1);
}
- #TODO this isn't compatible with Windows but would be if
- #EAGAIN was set to something that could never match
- #if on Windows
- } elsif ($! != EAGAIN) {
+ } else {
log_trace { "Got EOF or error, this read channel is done" };
Object::Remote->current_loop
->unwatch_io(