File Coverage

blib/lib/Evo/Promise/Sync.pm

Criterion	Covered	Total	%
statement	34	34	100.0
branch	16	22	72.7
condition			n/a
subroutine	5	5	100.0
pod	1	3	33.3
total	56	64	87.5

package Evo::Promise::Sync;
use Evo '-Class *';

has 'promise', ro;
has $_, optional for qw(called v blocking should_resolve);

sub reject ($self, $r) {
  return if $self->called;
  $self->called(1);
  $self->blocking ? $self->promise->d_reject($r) : $self->promise->d_reject_continue($r);
  $self;
}

sub resolve ($self, $v) {
  return if $self->called;
  $self->called(1);
  $self->blocking ? $self->should_resolve(1)->v($v) : $self->promise->d_resolve_continue($v);
  $self;
}

sub try_thenable ($self, $thenable) {
  $self->blocking(1);

  # reject drain second time, so don't bother checking "called"
  my ($res, $rej) = (sub { $self->resolve(@_) }, sub { $self->reject(@_) });
  eval { $thenable->then($res, $rej); 1; } or $self->reject($@);
  $self->blocking(0);
}

1;

__END__