my $stream = DX::ResultStream->new(for_state => make_state([ 'S' ], $op));
-is($stream->next->{'S'}, $_)
+is($stream->next->{'S'}->bound_value, $_)
for qw(jim.example.com joe.example.com bob.example.com);
is($stream->next, undef, 'No more');
)
);
+sub bound_values {
+ map {
+ my $v = $_;
+ +{
+ map +($_ => $v->{$_}->bound_value), keys %$v
+ }
+ } @_
+}
+
my $cstream = DX::ResultStream->new(
for_state => make_state([ qw(S P) ], $complex_op)
);
is_deeply(
- [ $cstream->results ],
+ [ bound_values $cstream->results ],
[
{ P => 'csh', S => 'jim.example.com' },
{ P => 'csh', S => 'joe.example.com' },
);
is_deeply(
- [ $callstream->results ],
+ [ bound_values $callstream->results ],
[
{ P => 'csh', S => 'jim.example.com' },
{ P => 'csh', S => 'joe.example.com' },
);
is_deeply(
- [ $orstream->results ],
+ [ bound_values $orstream->results ],
[
{
S => "kitty.scsys.co.uk"
);
is_deeply(
- [ $orstream_2->results ],
+ [ bound_values $orstream_2->results ],
[
{
S => "jim.example.com"