lib/Tak/Client.pm

   1 package Tak::Client;
   2
   3 use Tak;
   4 use Tak::Request;
   5 use Moo;
   6
   7 has service => (is => 'ro', required => 1);
   8
   9 has curried => (is => 'ro', default => sub { [] });
  10
  11 sub curry {
  12   my ($self, @curry) = @_;
  13   (ref $self)->new(%$self, curried => [ @{$self->curried}, @curry ]);
  14 }
  15
  16 sub send {
  17   my ($self, @message) = @_;
  18   $self->service->receive(@{$self->curried}, @message);
  19 }
  20
  21 sub start {
  22   my ($self, $register, @payload) = @_;
  23   my $req = $self->_new_request($register);
  24   $self->service->start_request($req, @{$self->curried}, @payload);
  25   return $req;
  26 }
  27
  28 sub request_class { 'Tak::Request' }
  29
  30 sub _new_request {
  31   my ($self, $args) = @_;
  32   $self->request_class->new($args);
  33 }
  34
  35 sub do {
  36   my ($self, @payload) = @_;
  37   my $done;
  38   my $result;
  39   my $req = $self->start({
  40     on_result => sub { $result = shift },
  41   }, @payload);
  42   Tak->loop_until($result);
  43   $result->get;
  44 }
  45
  46 1;