X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?p=scpubgit%2FObject-Remote.git;a=blobdiff_plain;f=lib%2FObject%2FRemote%2FConnectionServer.pm;h=352d329111c7d9cef79011a40dcfcfa28a4fb219;hp=da4a4d38702462693fcc713f95463e486ec206c4;hb=783105c4013747147c7195f043961af40b9908b7;hpb=e25b44e30036d670e9e827e2852e59882ad10ca5 diff --git a/lib/Object/Remote/ConnectionServer.pm b/lib/Object/Remote/ConnectionServer.pm index da4a4d3..352d329 100644 --- a/lib/Object/Remote/ConnectionServer.pm +++ b/lib/Object/Remote/ConnectionServer.pm @@ -4,6 +4,7 @@ use Scalar::Util qw(blessed weaken); use Module::Runtime qw(use_module); use Object::Remote; use Object::Remote::Logging qw( :log :dlog ); +use Future; use IO::Socket::UNIX; use Moo; @@ -53,7 +54,7 @@ sub _listen_ready { 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,