1 package Object::Remote::Future;
9 our @EXPORT = qw(future await_future);
12 my $f = $_[0]->(CPS::Future->new);
13 return $f if ((caller(1)||'') eq 'start');
19 return $f if $f->is_ready;
20 require Object::Remote;
21 my $loop = Object::Remote->current_loop;
22 $f->on_ready(sub { $loop->stop });
24 return wantarray ? $f->get : ($f->get)[0];
31 my ($method) = our $AUTOLOAD =~ /([^:]+)$/;
32 if (ref($invocant) eq 'ARRAY') {
33 return [ map $_->${\"start::${method}"}, @$invocant ];
36 unless (eval { $res = $invocant->$method(@_); 1 }) {
37 my $f = CPS::Future->new;
41 unless (Scalar::Util::blessed($res) and $res->isa('CPS::Future')) {
42 my $f = CPS::Future->new;
53 my ($method) = our $AUTOLOAD =~ /([^:]+)$/;
54 my @invocants = (ref($invocant) eq 'ARRAY' ? @$invocant : $invocant);
55 my @futures = map $_->${\"start::${method}"}, @$invocant;
56 Object::Remote::Future::await_future(CPS::Future->needs_all(@futures));
57 return map $_->get, @futures;