view release on metacpan or  search on metacpan

t/disconnect.t  view on Meta::CPAN

use Test::Base;

plan tests => 3;

use Test::TCP;

use AnyEvent::Socket;
use AnyEvent::JSONRPC;

my $port = empty_port;

my $state = 'initial';

my $handle;
my $server = tcp_server undef, $port, sub {
    my ($fh) = @_ or die $!;

    $state = 'connected';

    $handle = AnyEvent::Handle->new(
        fh     => $fh,
        on_error => sub {
            warn 'Server got: ', $_[2];
            $state = 'disconnected';
        },
        on_eof => sub {
            $state = 'disconnected';
        },
        on_read => sub {  },
    );
};

{
    my $client = jsonrpc_client '127.0.0.1', $port;
    # disconnect soon after leaving this scope
}

my $cv = AnyEvent->condvar;

my ($client, $timer1, $timer2);
my $t = AnyEvent->timer(
    after => 1,
    cb    => sub {
        is $state, 'disconnected', 'already disconnected ok';

        $client = jsonrpc_client '127.0.0.1', $port;
        $timer1 = AnyEvent->timer(
            after => 0.5,
            cb    => sub {
                is $state, 'connected', 'connected at this time ok';
                undef $client;  # disconnect here
            },
        );

        $timer2 = AnyEvent->timer(
            after => 1,
            cb    => sub {
                is $state, 'disconnected', 'connection disconnected ok';
                $cv->send;
            },
        );
    },
);

$cv->recv;