File Coverage

blib/lib/Message/Passing/Redis/ConnectionManager.pm

Criterion	Covered	Total	%
statement	15	24	62.5
branch			n/a
condition			n/a
subroutine	5	8	62.5
pod			n/a
total	20	32	62.5

package Message::Passing::Redis::ConnectionManager;
use Moo;
use Scalar::Util qw/ weaken /;
use Redis;
use AnyEvent;
use namespace::clean -except => 'meta';

with qw/
    Message::Passing::Role::ConnectionManager
    Message::Passing::Role::HasHostnameAndPort
/;

sub _default_port { 6379 }

sub _build_connection {
    my $self = shift;
    weaken($self);
    my $client = Redis->new(
        encoding => undef,
        server => sprintf("%s:%s", $self->hostname, $self->port),
    );
    # Delay calling set_connected till we've finished building the client
    my $i; $i = AnyEvent->idle(cb => sub {
        undef $i; $self->_set_connected(1);
    });
    return $client;
}

1;