Yet Another CPAN Grep

PocketIO ( V/VT/VTI/PocketIO-0.17.tar.gz, VTI, 2014; MetaCPAN )

PocketIO/lib/PocketIO/Pool/Redis.pm ( view source; MetaCPAN )

IO::Pool::Redis;

use strict;
use warnings;

use base 'PocketIO::Pool';

use AnyEvent::Redis;
use JSON;
use Scalar::Util qw(blessed);

use PocketIO::Connection;

use constant DEBUG => $ENV{POCKETIO_PO

self->{channel} => sub {
            my ($message, $channel) = @_;

            $message = decode_json($message);

            my $invoker_id = $message->{invoker};

            foreach my $conn ($sel

. $id . "'\n";

    $cb->() if $cb;
}

sub send {
    my $self = shift;

    my $message = encode_json({message => "$_[0]"});

    $self->{pub}->publish($self->{channel}, $message);

    return $self;