use Module::Runtime qw(use_module);
use Object::Remote;
use Object::Remote::Logging qw( :log :dlog );
+use Future;
use IO::Socket::UNIX;
use Moo;
my $new = $fh->accept or die "Couldn't accept: $!";
log_trace { "Setting file handle non-blocking" };
$new->blocking(0);
- my $f = CPS::Future->new;
+ my $f = Future->new;
log_trace { "Creating a new connection with the remote node" };
my $c = use_module('Object::Remote::Connection')->new(
receive_from_fh => $new,
$f->on_ready(sub { undef($c) });
log_trace { "marking the future as done" };
$c->ready_future->done;
- Dlog_trace { "Sending 'Shere' to socket $_" } $new;
+ Dlog_trace { "Sending 'Shere' to socket $_" } $new;
print $new "Shere\n" or die "Couldn't send to new socket: $!";
log_debug { "Connection has been fully handled" };
return $c;