lib/DX/Op/Observe.pm

   1 package DX::Op::Observe;
   2
   3 use DX::ObservationRequired;
   4 use Moo;
   5
   6 with 'DX::Role::Op';
   7
   8 has vars => (is => 'ro', required => 1);
   9 has builder => (is => 'ro', required => 1);
  10
  11 has _arg_map => (is => 'lazy', builder => sub {
  12   my ($self) = @_;
  13   my $name = 'arg0';
  14   +{ map +($name++, $_), @{$self->vars} };
  15 });
  16
  17 sub run {
  18   my ($self, $state) = @_;
  19   ($state, my %args) = $self->_expand_args($state, %{$self->_arg_map});
  20   my @vars = map $_->bound_value, @args{sort keys %args};
  21   my $observer = $self->builder->(@vars);
  22   $state->return_from_run(
  23     DX::ObservationRequired->new(
  24       observer => $observer,
  25       resume => $state->then($self->next)
  26     )
  27   );
  28 }
  29
  30 1;