X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FObject%2FRemote%2FConnectionServer.pm;h=352d329111c7d9cef79011a40dcfcfa28a4fb219;hb=ee6a17a6ac2aaa0a06cc4ba326b4e0b377b429dc;hp=da4a4d38702462693fcc713f95463e486ec206c4;hpb=55c0d0209fa9d9265ff178f54ae9fe5fdddef3c1;p=scpubgit%2FObject-Remote.git 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,