view release on metacpan or  search on metacpan

bin/queue  view on Meta::CPAN

    sub run ($command) {
        say STDERR "run" if $Debug;
        $command->connect;
        Mojo::IOLoop->start;
    }

    sub connect ($command) {
        say STDERR "connect" if $Debug;
        my $url = $command->app->config->{uploads_socket};

        Scalar::Util::weaken $command;
        $command->ua->websocket($url => sub ($, $tx) {
            unless ($tx->is_websocket) {
                $command->app->log->warn("Not a websocket");
                Mojo::IOLoop->timer(1 => sub { $command->connect });
                return;
            }

            say STDERR "CONNECTED" if $Debug;
            my $waiting;