File Coverage

blib/lib/Tak/ConnectionService.pm

Criterion	Covered	Total	%
statement	9	18	50.0
branch			n/a
condition			n/a
subroutine	3	6	50.0
pod	0	3	0.0
total	12	27	44.4

package Tak::ConnectionService;

use Tak::ConnectionReceiver;
use Tak::JSONChannel;
use Moo;

has receiver => (is => 'ro', writer => '_set_receiver');

has channel => (is => 'ro', writer => '_set_channel');

sub BUILD {
  my ($self, $args) = @_;
  my $channel = $self->_set_channel(
    Tak::JSONChannel->new(map +($_ => $args->{$_}), qw(read_fh write_fh))
  );
  my $receiver = $self->_set_receiver(
    Tak::ConnectionReceiver->new(
      channel => $channel, service => $args->{listening_service},
      on_close => $args->{on_close},
    )
  );
}

sub start_request {
  my ($self, $req, @payload) = @_;
  $self->receiver->requests->{my $tag = "$req"} = $req;
  my $meta = { progress => !!$req->on_progress };
  $self->channel->write_message(request => $tag => $meta => @payload);
}

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

1;