X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?p=scpubgit%2FObject-Remote.git;a=blobdiff_plain;f=lib%2FObject%2FRemote.pm;h=47f2906e088cc1806353c7f3431f17df8df70170;hp=680197e91915566eb5df26b41d0b26d4c30889de;hb=676438a11cbf6bd49102369824c9d87f70964fd3;hpb=3f1f1e662b0737ba6225973b88f2d78dd2344314 diff --git a/lib/Object/Remote.pm b/lib/Object/Remote.pm index 680197e..47f2906 100644 --- a/lib/Object/Remote.pm +++ b/lib/Object/Remote.pm @@ -1,85 +1,24 @@ package Object::Remote; use Object::Remote::MiniLoop; -use Object::Remote::Proxy; -use Scalar::Util qw(weaken blessed); -use Object::Remote::Future; -use Module::Runtime qw(use_module); -use Moo; +use Object::Remote::Handle; sub new::on { my ($class, $on, @args) = @_; - __PACKAGE__->new( + Object::Remote::Handle->new( connection => $on, class => $class, args => \@args )->proxy; } -has connection => ( - is => 'ro', required => 1, - coerce => sub { - blessed($_[0]) - ? $_[0] - : use_module('Object::Remote::Connection')->new_from_spec($_[0]) - }, -); - -has id => (is => 'rwp'); - -has disarmed_free => (is => 'rwp'); - -sub disarm_free { $_[0]->_set_disarmed_free(1); $_[0] } - -sub proxy { - bless({ remote => $_[0], method => 'call' }, 'Object::Remote::Proxy'); -} - -sub BUILD { - my ($self, $args) = @_; - unless ($self->id) { - die "No id supplied and no class either" unless $args->{class}; - ref($_) eq 'HASH' and $_ = [ %$_ ] for $args->{args}; - $self->_set_id( - await_future( - $self->connection->send( - class_call => $args->{class}, 0, - $args->{constructor}||'new', @{$args->{args}||[]} - ) - )->{remote}->disarm_free->id - ); - } - $self->connection->register_remote($self); +sub new { + shift; + Object::Remote::Handle->new(@_)->proxy; } sub current_loop { our $Current_Loop ||= Object::Remote::MiniLoop->new } -sub call { - my ($self, $method, @args) = @_; - my $w = wantarray; - $method = "start::${method}" if (caller(0)||'') eq 'start'; - future { - $self->connection->send(call => $self->id, $w, $method, @args) - }; -} - -sub call_discard { - my ($self, $method, @args) = @_; - $self->connection->send_discard(call => $self->id, $method, @args); -} - -sub call_discard_free { - my ($self, $method, @args) = @_; - $self->disarm_free; - $self->connection->send_discard(call_free => $self->id, $method, @args); -} - -sub DEMOLISH { - my ($self, $gd) = @_; - return if $gd or $self->disarmed_free; - $self->connection->send_free($self->id); -} - 1;