use Module::Runtime qw(use_module);
use Scalar::Util qw(weaken blessed refaddr openhandle);
use JSON::PP qw(encode_json);
-use Moo;
+use Future;
use Carp qw(croak);
+use Moo;
BEGIN { router()->exclude_forwarding }
);
has on_close => (
- is => 'rw', default => sub { $_[0]->_install_future_handlers(CPS::Future->new) },
+ is => 'rw', default => sub { $_[0]->_install_future_handlers(Future->new) },
trigger => sub {
log_trace { "Installing handlers into future via trigger" };
$_[0]->_install_future_handlers($_[1])
sub send {
my ($self, $type, @call) = @_;
- my $future = CPS::Future->new;
+ my $future = Future->new;
my $remote = $self->remote_objects_by_id->{$call[0]};
unshift @call, $type => $self->_local_object_to_id($future);