X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?p=scpubgit%2FObject-Remote.git;a=blobdiff_plain;f=lib%2FObject%2FRemote%2FRole%2FConnector.pm;h=6da4a9c5331a2f1497f8bea7088c00d8534bb138;hp=cc8684b6b0bf703090da1cfec935348a9d42aa0a;hb=cc670b3044ce1fc9389d9845ee5ea91459f2612e;hpb=12fb4a80d68ad14c18a35f60cc6d8a671f728ac9 diff --git a/lib/Object/Remote/Role/Connector.pm b/lib/Object/Remote/Role/Connector.pm index cc8684b..6da4a9c 100644 --- a/lib/Object/Remote/Role/Connector.pm +++ b/lib/Object/Remote/Role/Connector.pm @@ -6,6 +6,8 @@ use Moo::Role; requires '_open2_for'; +has timeout => (is => 'ro', default => sub { { after => 10 } }); + sub connect { my $self = shift; my ($send_to_fh, $receive_from_fh, $child_pid) = $self->_open2_for(@_); @@ -34,7 +36,7 @@ sub connect { }); Object::Remote->current_loop ->watch_time( - after => 5, + %{$self->timeout}, code => sub { $f->fail("Connection timed out") unless $f->is_ready; undef($channel);