1 package DX::Op::Observe;
3 use DX::ObservationRequired;
8 has vars => (is => 'ro', required => 1);
9 has builder => (is => 'ro', required => 1);
11 has _arg_map => (is => 'lazy', builder => sub {
14 +{ map +($name++, $_), @{$self->vars} };
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)