1 package DX::ResultStream;
5 has for_state => (is => 'ro', required => 1);
7 has _current_state => (is => 'rw');
9 has is_exhausted => (is => 'rwp');
13 return if $self->is_exhausted;
14 my $start_state = do {
15 if (my $cur = $self->_current_state) {
21 my $state = $self->_current_state($start_state->run);
23 $self->_set_is_exhausted(1);
27 map +($_ => $state->scope_var($_)->bound_value), keys %{$state->scope}