1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
use v5.10;
use strict;
use warnings;
use Test2::V0;
use Future;
my $__dummy; # to defeat non-closure optimsation
# then done
{
my $f1 = Future->new;
my ( $cbt, $cbe );
my $fdone;
my $fseq = $f1->then(
$cbt = sub {
is( $_[0], "f1 result", '2-arg then done block passed result of $f1' );
return $fdone = Future->new;
},
$cbe = sub {
$__dummy++;
die "then fail block should not be invoked";
},
);
is_refcount( $cbt, 2, '$cbt has refcount 2 captured by then callback' );
is_refcount( $cbe, 2, '$cbe has refcount 2 captured by then callback' );
$f1->done( "f1 result" );
ok( defined $fdone, '$fdone now defined after $f1 done' );
$fdone->done( results => "here" );
ok( $fseq->is_ready, '$fseq is done after $fdone done' );
is( [ $fseq->result ], [ results => "here" ], '$fseq->result returns results' );
is_oneref( $cbt, '$cbt has refcount 1 at EOF' );
is_oneref( $cbe, '$cbe has refcount 1 at EOF' );
}
# then fail
{
my $f1 = Future->new;
my $ffail;
my $fseq = $f1->then(
sub {
die "then done block should not be invoked";
},
sub {
is( $_[0], "The failure\n", '2-arg then fail block passed failure of $f1' );
return $ffail = Future->new;
},
);
$f1->fail( "The failure\n" );
ok( defined $ffail, '$ffail now defined after $f1 fail' );
$ffail->done( fallback => "result" );
ok( $fseq->is_ready, '$fseq is done after $ffail fail' );
is( [ $fseq->result ], [ fallback => "result" ], '$fseq->result returns results' );
}
# then done immediate
{
my $f1 = Future->done;
my ( $cbt, $cbe );
my $fdone;
my $fseq = $f1->then(
$cbt = sub { return $fdone = Future->new },
$cbe = sub {
$__dummy++;
die "then fail block should not be invoked";
},
);
$fdone->done( results => "here" );
ok( $fseq->is_ready, '$fseq is done after $fdone done' );
is( [ $fseq->result ], [ results => "here" ], '$fseq->result returns results' );
is_oneref( $cbt, '$cbt has refcount 1 at EOF' );
is_oneref( $cbe, '$cbe has refcount 1 at EOF' );
}
# then done fails doesn't trigger fail block
{
my $f1 = Future->new;
my $fdone;
my $fseq = $f1->then(
sub {
$fdone = Future->new;
},
sub {
die "then fail block should not be invoked";
},
);
$f1->done( "Done" );
$fdone->fail( "The failure\n" );
ok( $fseq->is_ready, '$fseq is ready after $fdone fail' );
ok( scalar $fseq->failure, '$fseq failed after $fdone fail' );
}
# then_with_f
{
my $f1 = Future->new;
my $fseq = $f1->then_with_f(
sub {
ref_is( $_[0], $f1, 'then_with_f done block passed $f1' );
is( $_[1], "f1 result", 'then_with_f done block passed result of $f1' );
Future->done;
},
sub {
die "then_with_f fail block should not be called";
},
);
$f1->done( "f1 result" );
ok( $fseq->is_ready, '$fseq is ready after $f1 done' );
}
done_testing;
|
