7 has service => (is => 'ro', required => 1);
9 has curried => (is => 'ro', default => sub { [] });
12 my ($self, @curry) = @_;
13 (ref $self)->new(%$self, curried => [ @{$self->curried}, @curry ]);
17 my ($self, @message) = @_;
18 $self->service->receive(@{$self->curried}, @message);
22 my ($self, $register, @payload) = @_;
23 my $req = $self->_new_request($register);
24 $self->service->start_request($req, @{$self->curried}, @payload);
28 sub request_class { 'Tak::Request' }
31 my ($self, $args) = @_;
32 $self->request_class->new($args);
36 shift->result_of(@_)->get;
40 my ($self, @payload) = @_;
43 my $req = $self->start({
44 on_result => sub { $result = shift },
46 Tak->loop_until($result);