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
|
#!/usr/bin/perl
use v5.14;
use warnings;
use Test::More;
use Future;
use Event::Distributor;
# async->async
{
my $dist = Event::Distributor->new;
$dist->declare_signal( "alert" );
my $called_f;
my $called_dist;
my @called_args;
$dist->subscribe_async( alert => sub {
$called_dist = shift;
@called_args = @_;
return $called_f = Future->new
});
my $f = $dist->fire_async( alert => "args", "here" );
ok( $f, '->fire_async yields signal' );
ok( !$f->is_ready, '$f not yet ready' );
is( $called_dist, $dist, 'First arg to subscriber is $dist' );
is_deeply( \@called_args, [ "args", "here" ], 'Args to subscriber' );
$called_f->done();
ok( $f->is_ready, '$f is now ready after $called_f->done' );
is_deeply( [ $f->get ], [], '$f->get yields nothing' );
}
# pre-registration of subscriber
{
my $dist = Event::Distributor->new;
my $called;
$dist->subscribe_sync( wibble => sub { $called++ } );
$dist->declare_signal( "wibble" );
$dist->fire_sync( wibble => );
ok( $called, 'Preregistered subscriber is invoked' );
}
# subscribe_sync
{
my $dist = Event::Distributor->new;
$dist->declare_signal( "alert" );
my $called;
$dist->subscribe_sync( alert => sub { $called++ } );
my $f = $dist->fire_async( alert => );
ok( $f->is_ready, '$f already ready for only sync subscriber' );
ok( $called, 'Synchronous subscriber actually called' );
}
# fire_sync
{
my $dist = Event::Distributor->new;
$dist->declare_signal( "alert" );
$dist->subscribe_async( alert => sub { Future->done } );
$dist->fire_sync( alert => );
pass( 'Synchronous fire returns immediately' );
}
# subscriber death is not fatal to queries
{
my $dist = Event::Distributor->new;
$dist->declare_query( "question" );
$dist->subscribe_sync( question => sub { die "Oopsie\n" } );
$dist->subscribe_sync( question => sub { return "OK" } );
is( $dist->fire_sync( question => ), "OK",
'Synchronous subscriber death is not fatal to query' );
}
done_testing;
|
