File Coverage

blib/lib/Promises6/Listener.pm

Criterion	Covered	Total	%
statement	25	25	100.0
branch	10	12	83.3
condition			n/a
subroutine	3	3	100.0
pod	1	1	100.0
total	39	41	95.1

package Promises6::Listener;
use Evo::Base -base;
use Promises6::Util 'PROGRESS';

has [qw(deferred builder)];

# onFulfill, onReject, onProgress
has cbs => sub { [] };

sub get_msg($self, $state, $val) {
  my $deferred = $self->deferred;
  my $cb       = $self->cbs->[$state];

  # then. 1.i, 1.ii
  unless (ref $cb eq 'CODE') {
    $state == PROGRESS
      ? $deferred->notify($val)
      : $deferred->change_state($state, $val);
    return;
  }

  # then 7.ii
  my $err;
CATCH: {
    local $@;
    $val = eval { $cb->($val) };
    $err = $@;
  }
  return $deferred->reject($err) if $err;

  $state == PROGRESS ? $deferred->notify($val) : $deferred->resolve($val);
}

1;

# ABSTRACT: A listener.

__END__