factor out ArrayStream, update new stream types to respect peek

diff --git a/lib/HTML/Zoom/ArrayStream.pm b/lib/HTML/Zoom/ArrayStream.pm
new file mode 100644 (file)
index 0000000..7a7e05c
--- /dev/null
+++ b/lib/HTML/Zoom/ArrayStream.pm
@@ -0,0 +1,21 @@
+package HTML::Zoom::ArrayStream;
+
+use strict;
+use warnings FATAL => 'all';
+use base qw(HTML::Zoom::StreamBase);
+
+sub new {
+  my ($class, $args) = @_;
+  bless(
+    { _zconfig => $args->{zconfig}, _array => [ @{$args->{array}} ] },
+    $class
+  );
+}
+
+sub _next {
+  my $ary = $_[0]->{_array};
+  return unless @$ary;
+  return shift @$ary;
+}
+
+1;

diff --git a/lib/HTML/Zoom/CodeStream.pm b/lib/HTML/Zoom/CodeStream.pm
index 1d70a58..0755a3b 100644 (file)
--- a/lib/HTML/Zoom/CodeStream.pm
+++ b/lib/HTML/Zoom/CodeStream.pm
@@ -4,29 +4,13 @@ use strict;
 use warnings FATAL => 'all';
 use base qw(HTML::Zoom::StreamBase);
 
-sub from_array {
-  my ($class, @array) = @_;
-  $class->new({ code => sub {
-    return unless @array;
-    return shift @array;
-  }});
-}
-
 sub new {
   my ($class, $args) = @_;
   bless({ _code => $args->{code}, _zconfig => $args->{zconfig} }, $class);
 }
 
-sub next {
-  my ($self) = @_;
-
-  # peeked entry so return that
-
-  if (exists $self->{_peeked}) {
-    return (delete $self->{_peeked});
-  }
-
-  $self->{_code}->();
+sub _next {
+  $_[0]->{_code}->();
 }
 
 1;

diff --git a/lib/HTML/Zoom/FilterStream.pm b/lib/HTML/Zoom/FilterStream.pm
index e6d7a83..a0bc6b7 100644 (file)
--- a/lib/HTML/Zoom/FilterStream.pm
+++ b/lib/HTML/Zoom/FilterStream.pm
@@ -17,15 +17,9 @@ sub new {
   );
 }
 
-sub next {
+sub _next {
   my ($self) = @_;
 
-  # peeked entry so return that
-
-  if (exists $self->{_peeked}) {
-    return (delete $self->{_peeked});
-  }
-
   # if our main stream is already gone then we can short-circuit
   # straight out - there's no way for an alternate stream to be there
 

diff --git a/lib/HTML/Zoom/FlattenedStream.pm b/lib/HTML/Zoom/FlattenedStream.pm
index 28c44c2..d33c9ea 100644 (file)
--- a/lib/HTML/Zoom/FlattenedStream.pm
+++ b/lib/HTML/Zoom/FlattenedStream.pm
@@ -9,7 +9,8 @@ sub new {
   bless({ _source => $args->{source}, _zconfig => $args->{zconfig} }, $class);
 }
 
-sub next {
+sub _next {
+
   return unless (my $self = shift)->{_source};
   my ($next, $s);
   until (($next) = ($s = $self->{_cur}) ? $s->next : ()) {

diff --git a/lib/HTML/Zoom/MappedStream.pm b/lib/HTML/Zoom/MappedStream.pm
index 09ef6be..7d0c505 100644 (file)
--- a/lib/HTML/Zoom/MappedStream.pm
+++ b/lib/HTML/Zoom/MappedStream.pm
@@ -12,7 +12,7 @@ sub new {
   }, $class);
 }
 
-sub next {
+sub _next {
   return unless (my $self = shift)->{_source};
   # If we were aiming for a "true" perl-like map then we should
   # elegantly handle the case where the map function returns 0 events

diff --git a/lib/HTML/Zoom/StreamBase.pm b/lib/HTML/Zoom/StreamBase.pm
index c04c7b6..a733656 100644 (file)
--- a/lib/HTML/Zoom/StreamBase.pm
+++ b/lib/HTML/Zoom/StreamBase.pm
@@ -11,12 +11,25 @@ sub peek {
   if (exists $self->{_peeked}) {
     return ($self->{_peeked});
   }
-  if (my ($peeked) = $self->next) {
+  if (my ($peeked) = $self->_next) {
     return ($self->{_peeked} = $peeked);
   }
   return;
 }
 
+sub next {
+  my ($self) = @_;
+
+  # peeked entry so return that
+
+  if (exists $self->{_peeked}) {
+    return (delete $self->{_peeked});
+  }
+
+  $self->_next;
+}
+
+
 sub flatten {
   my $self = shift;
   require HTML::Zoom::FlattenedStream;

diff --git a/lib/HTML/Zoom/StreamUtils.pm b/lib/HTML/Zoom/StreamUtils.pm
index c30500c..3b2f921 100644 (file)
--- a/lib/HTML/Zoom/StreamUtils.pm
+++ b/lib/HTML/Zoom/StreamUtils.pm
@@ -8,6 +8,7 @@ use Scalar::Util ();
 
 use HTML::Zoom::CodeStream;
 use HTML::Zoom::FilterStream;
+use HTML::Zoom::ArrayStream;
 
 sub stream_from_code {
   my ($self, $code) = @_;
@@ -20,10 +21,10 @@ sub stream_from_code {
 sub stream_from_array {
   my $self = shift;
   my @array = @_;
-  $self->stream_from_code(sub {
-    return unless @array;
-    return shift @array;
-  });
+  HTML::Zoom::ArrayStream->new({
+    array => \@array,
+    zconfig => $self->_zconfig,
+  })
 }
 
 sub stream_concat {

diff --git a/t/actions.t b/t/actions.t
index 5e9bf16..1d83aa1 100644 (file)
--- a/t/actions.t
+++ b/t/actions.t
@@ -268,12 +268,12 @@ is(
     $_->repeat_content(
       [
         sub {
-          HTML::Zoom::CodeStream->from_array(
+          HTML::Zoom::ArrayStream->new({ array => [
             (filter
               filter($_ => '.name' => $r_content->('mst'))
               => '.career' => $r_content->('Chainsaw Wielder')),
-            HTML::Zoom::CodeStream->from_array(@between)
-          )->flatten
+            HTML::Zoom::ArrayStream->new({ array => \@between })
+          ] })->flatten
         },
         sub {
           filter