view release on metacpan or  search on metacpan

t/27-review-coverage.t  view on Meta::CPAN

        on_connect => sub { EV::break },
        on_error   => sub { EV::break },
    );

    my @during = $ctx->connections;   # synchronous: client is still "connecting"
    is(scalar(@during), 0, "connections() excludes a still-connecting conn");

    my $to = EV::timer(10, 0, sub { diag "Timeout!"; EV::break });
    EV::run;

    my @after = $ctx->connections;    # client + server endpoints now open
    ok(scalar(@after) >= 1, "connections() includes the established conn(s)");
    $keep{cli}->close(1000) if $keep{cli};
}

# 10. send_fragment binary path: binary fragments reassemble into one binary
#     message; $is_binary on continuation frames is ignored (type set by first).
{
    my $ctx = EV::Websockets::Context->new();
    my %keep;
    my ($got_data, $got_binary, $closed);