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
|
#!/usr/bin/perl -w
use strict;
use IO::Async::Test;
use Test::More tests => 10;
use Test::Identity;
use IO::Async::Loop::Poll;
my $loop = IO::Async::Loop::Poll->new;
testing_loop( $loop );
my %connectargs;
sub IO::Async::Loop::FOO_connect
{
my $self = shift;
%connectargs = @_;
identical( $self, $loop, 'FOO_connect invocant is $loop' );
}
my $sock;
$loop->connect(
extensions => [qw( FOO )],
some_param => "here",
on_connected => sub { $sock = shift },
);
is( ref delete $connectargs{on_connected}, "CODE", 'FOO_connect received on_connected continuation' );
is_deeply( \%connectargs,
{ some_param => "here" },
'FOO_connect received some_param and no others' );
$loop->connect(
extensions => [qw( FOO BAR )],
param1 => "one",
param2 => "two",
on_connected => sub { $sock = shift },
);
delete $connectargs{on_connected};
is_deeply( \%connectargs,
{ extensions => [qw( BAR )],
param1 => "one",
param2 => "two" },
'FOO_connect still receives other extensions' );
my %listenargs;
sub IO::Async::Loop::FOO_listen
{
my $self = shift;
%listenargs = @_;
identical( $self, $loop, 'FOO_listen invocant is $loop' );
}
$loop->listen(
extensions => [qw( FOO )],
some_param => "here",
on_accept => sub { $sock = shift },
);
is( ref delete $listenargs{on_accept}, "CODE", 'FOO_listen received on_accept continuation' );
is_deeply( \%listenargs,
{ some_param => "here" },
'FOO_listen received some_param and no others' );
$loop->listen(
extensions => [qw( FOO BAR )],
param1 => "one",
param2 => "two",
on_accept => sub { $sock = shift },
);
delete $listenargs{on_accept};
is_deeply( \%listenargs,
{ extensions => [qw( BAR )],
param1 => "one",
param2 => "two" },
'FOO_listen still receives other extensions' );
|
