Commit | Line | Data |
dc28afe8 |
1 | package Object::Remote::Future; |
2 | |
3 | use strict; |
4 | use warnings; |
5 | use base qw(Exporter); |
6 | |
7 | use CPS::Future; |
8 | |
9 | our @EXPORT = qw(future await_future); |
10 | |
11 | sub future (&) { |
12 | my $f = $_[0]->(CPS::Future->new); |
13 | return $f if ((caller(1)||'') eq 'start'); |
14 | await_future($f); |
15 | } |
16 | |
17 | sub await_future { |
18 | my $f = shift; |
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 }); |
23 | $loop->run; |
24 | return wantarray ? $f->get : ($f->get)[0]; |
25 | } |
26 | |
27 | package start; |
28 | |
29 | sub AUTOLOAD { |
30 | my $invocant = shift; |
31 | my ($method) = our $AUTOLOAD =~ /([^:]+)$/; |
32 | if (ref($invocant) eq 'ARRAY') { |
33 | return [ map $_->${\"start::${method}"}, @$invocant ]; |
34 | } |
35 | my $res; |
36 | unless (eval { $res = $invocant->$method(@_); 1 }) { |
37 | my $f = CPS::Future->new; |
38 | $f->fail($@); |
39 | return $f; |
40 | } |
41 | unless (Scalar::Util::blessed($res) and $res->isa('CPS::Future')) { |
42 | my $f = CPS::Future->new; |
43 | $f->done($res); |
44 | return $f; |
45 | } |
46 | return $res; |
47 | } |
48 | |
49 | package await; |
50 | |
51 | sub AUTOLOAD { |
52 | my $invocant = shift; |
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; |
58 | } |
59 | |
60 | 1; |