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
|
#!/usr/bin/perl -w
use strict;
use Test::More tests => 5;
use Test::Fatal;
use Async::MergePoint;
my $merge = Async::MergePoint->new();
ok( defined $merge, 'Empty MergePoint created' );
my $done;
$merge->close( on_finished => sub { $done = 1 } );
is( $done, 1, 'Closing a null MergePoint fires callback' );
$merge = Async::MergePoint->new();
$merge->needs( 'foo' );
$merge->close( on_finished => sub { $done = 2 } );
is( $done, 1, 'Closing a not ready MergePoint does not callback' );
ok( exception { $merge->needs( 'bar' ) },
'Extending an already-closed MergePoint fails' );
$merge->done( 'foo' );
is( $done, 2, 'Callback now fires' );
|
