[scpubgit/Tak.git] / lib / Tak / Remote.pm

package Tak::Remote;

use Moo;

has router => (is => 'ro', required => 1);

has name => (is => 'ro', required => 1);

sub blocking_request {
  my ($self, @payload) = @_;
  my ($done, @result);
  my $cb = sub { my ($self, $tag, @r) = @_; @result = @r; $done = 1; };
  $self->router->send_request($self, $cb, $self->name, @payload);
  $self->router->run_until($done);
  return @result;
}

1;
Commit	Line	Data
36cf3bcb	1	package Tak::Remote;
	2
	3	use Moo;
	4
	5	has router => (is => 'ro', required => 1);
	6
	7	has name => (is => 'ro', required => 1);
	8
	9	sub blocking_request {
	10	my ($self, @payload) = @_;
ca30c15e	11	my ($done, @result);
	12	my $cb = sub { my ($self, $tag, @r) = @_; @result = @r; $done = 1; };
	13	$self->router->send_request($self, $cb, $self->name, @payload);
	14	$self->router->run_until($done);
	15	return @result;
36cf3bcb	16	}
	17
	18	1;