1 package Object::Remote::Future;
9 our @EXPORT = qw(future await_future await_all);
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];
28 await_future(CPS::Future->needs_all(@_));
36 my ($method) = our $AUTOLOAD =~ /^start::(.+)$/;
37 if (ref($invocant) eq 'ARRAY') {
38 return [ map $_->${\"start::${method}"}, @$invocant ];
41 unless (eval { $res = $invocant->$method(@_); 1 }) {
42 my $f = CPS::Future->new;
46 unless (Scalar::Util::blessed($res) and $res->isa('CPS::Future')) {
47 my $f = CPS::Future->new;