lib/Object/Remote/Future.pm

   1 package Object::Remote::Future;
   2
   3 use strict;
   4 use warnings;
   5 use base qw(Exporter);
   6
   7 use CPS::Future;
   8
   9 our @EXPORT = qw(future await_future);
  10
  11 sub future (&) {
  12   my $f = $_[0]->(CPS::Future->new);
  13   return $f if ((caller(1)||'') eq 'start');
  14   await_future($f);
  15 }
  16
  17 sub await_future {
  18   my $f = shift;
  19   return $f if $f->is_ready;
  20   require Object::Remote;
  21   my $loop = Object::Remote->current_loop;
  22   $f->on_ready(sub { $loop->stop });
  23   $loop->run;
  24   return wantarray ? $f->get : ($f->get)[0];
  25 }
  26
  27 package start;
  28
  29 sub AUTOLOAD {
  30   my $invocant = shift;
  31   my ($method) = our $AUTOLOAD =~ /([^:]+)$/;
  32   if (ref($invocant) eq 'ARRAY') {
  33     return [ map $_->${\"start::${method}"}, @$invocant ];
  34   }
  35   my $res;
  36   unless (eval { $res = $invocant->$method(@_); 1 }) {
  37     my $f = CPS::Future->new;
  38     $f->fail($@);
  39     return $f;
  40   }
  41   unless (Scalar::Util::blessed($res) and $res->isa('CPS::Future')) {
  42     my $f = CPS::Future->new;
  43     $f->done($res);
  44     return $f;
  45   }
  46   return $res;
  47 }
  48
  49 package await;
  50
  51 sub AUTOLOAD {
  52   my $invocant = shift;
  53   my ($method) = our $AUTOLOAD =~ /([^:]+)$/;
  54   my @invocants = (ref($invocant) eq 'ARRAY' ? @$invocant : $invocant);
  55   my @futures = map $_->${\"start::${method}"}, @$invocant;
  56   Object::Remote::Future::await_future(CPS::Future->needs_all(@futures));
  57   return map $_->get, @futures;
  58 }
  59
  60 1;