view release on metacpan or  search on metacpan

t/testlib/PSGI.pm  view on Meta::CPAN

our @EXPORT_OK = qw(run_tests);

my $cv_server_finish;
    
sub _make_app {
    my ($ws_server) = @_;
    return sub {
        my ($env) = @_;
        return sub {
            my $responder = shift;
            note("server enters streaming callback");
            $cv_server_finish->begin;
            $ws_server->establish_psgi($env)->cb(sub {
                my $cv = shift;
                my ($conn, $validate_str) = try { $cv->recv };
                if(!$conn) {
                    note("server connection error");
                    $responder->([400, ['Content-Type' => 'text/plain', 'Connection' => 'close'], ['invalid request']]);
                    $cv_server_finish->end;
                    return;
                }