use Test::More;
use aliased 'DX::Op::FromCode';
use aliased 'DX::ArrayStream';
-use DX::ResultStream;
use DX::Var;
use DX::State;
use DX::ObservationRequired;
my $path = $state->scope_var('P')->bound_value;
$state->return_from_run(
DX::ObservationRequired->new(
- observation => sub { $paths{$path} = $observe_path{$path} },
+ observer => sub { $paths{$path} = $observe_path{$path} },
resume => $state->then($self->next),
)
);
my $ob_req = $or_state->run;
-$ob_req->observation->();
+$ob_req->observer->();
{
my $res = $ob_req->resume->run;