--- AnyEvent/t/handle/04_listen.t 2008/05/02 09:07:02 1.5 +++ AnyEvent/t/handle/04_listen.t 2008/05/02 09:15:34 1.6 @@ -14,13 +14,27 @@ my $lsock = AnyEvent::Socket->new ( Listen => 1, - LocalPort => 32391, ReuseAddr => 1, ); +$lsock->on_accept (sub { + my ($lsock, $cl, $paddr) = @_; + + unless (defined $cl) { + diag "accept failed: $!"; + return; + } + + $cl->read (6, sub { + my ($cl, $data) = @_; + $lbytes = $data; + $cl->write ("BLABLABLA\015\012"); + }); +}); + my $ae_sock = AnyEvent::Socket->new ( - PeerAddr => "127.0.0.1:32391", + PeerAddr => "127.0.0.1:" . $lsock->fh->sockport, on_connect => sub { my ($ae_sock, $error) = @_; if ($error) { diag "connection failed: $!"; $cv->broadcast; return } @@ -38,21 +52,6 @@ $ae_sock->on_eof (sub { $cv->broadcast }); -$lsock->on_accept (sub { - my ($lsock, $cl, $paddr) = @_; - - unless (defined $cl) { - diag "accept failed: $!"; - return; - } - - $cl->read (6, sub { - my ($cl, $data) = @_; - $lbytes = $data; - $cl->write ("BLABLABLA\015\012"); - }); -}); - $cv->wait; is ($lbytes, "TEST\015\012", 'listening end received data');