Yet Another CPAN Grep

Mojo-WebSocketProxy-Backend-ConsumerGroups ( D/DE/DERIV/Mojo-WebSocketProxy-Backend-ConsumerGroups-0.07.tar.gz, DERIV, 2024; MetaCPAN )

Mojo-WebSocketProxy-Backend-ConsumerGroups/lib/Mojo/WebSocketProxy/Backend/ConsumerGroups.pm ( view source; MetaCPAN )

 IO::Async::Loop::Mojo;
use Data::UUID;
use JSON::MaybeUTF8 qw(encode_json_utf8 decode_json_utf8);
use Syntax::Keyword::Try;
use curry::weak;
use MojoX::JSON::RPC::Client;

use parent qw(Mojo::WebSock

storage) }

            return Future->done unless $c && $c->tx;

            my $result = MojoX::JSON::RPC::Client::ReturnObject->new(rpc_response => $message->{response});

            foreach my $h

Error', 'Sorry, an error occurred while processing your request.');
                $send_func->({json => $api_response}, $req_storage);
                return Future->done;
            }