Commit | Line | Data |
11e7c8a5 |
1 | use strictures 1; |
2 | use Test::More; |
3 | |
4 | { |
5 | package S1S; |
6 | |
7 | use Moo; |
8 | |
9 | sub get_s2 { |
10 | S2S->new |
11 | } |
12 | } |
13 | |
14 | { |
15 | package S1F; |
16 | |
17 | use Object::Remote::Future; |
18 | use Moo; |
19 | |
20 | our $C; |
21 | |
22 | sub get_s2 { |
23 | future { |
24 | my $f = shift; |
25 | $C = sub { $f->done(S2F->new); undef($f); }; |
26 | $f; |
27 | } |
28 | } |
29 | } |
30 | |
31 | { |
32 | package S2S; |
33 | |
34 | use Moo; |
35 | |
36 | sub get_s3 { 'S3' } |
37 | } |
38 | |
39 | { |
40 | package S2F; |
41 | |
42 | use Object::Remote::Future; |
43 | use Moo; |
44 | |
45 | our $C; |
46 | |
47 | sub get_s3 { |
48 | future { |
49 | my $f = shift; |
50 | $C = sub { $f->done('S3'); undef($f); }; |
51 | $f; |
52 | } |
53 | } |
54 | } |
55 | |
56 | my $res; |
57 | |
58 | S1S->start::get_s2->then::get_s3->on_ready(sub { ($res) = $_[0]->get }); |
59 | |
60 | is($res, 'S3', 'Synchronous code ok'); |
61 | |
62 | undef($res); |
63 | |
64 | S1F->start::get_s2->then::get_s3->on_ready(sub { ($res) = $_[0]->get }); |
65 | |
66 | ok(!$S2F::C, 'Second future not yet constructed'); |
67 | |
68 | $S1F::C->(); |
69 | |
70 | ok($S2F::C, 'Second future constructed after first future completed'); |
71 | |
72 | ok(!$res, 'Nothing happened yet'); |
73 | |
74 | $S2F::C->(); |
75 | |
76 | is($res, 'S3', 'Asynchronous code ok'); |
77 | |
78 | done_testing; |