lib/io_streams/streams.rb in iostreams-1.0.0.beta2 vs lib/io_streams/streams.rb in iostreams-1.0.0.beta3

@@ -115,10 +115,10 @@
       elsif pipeline.size == 1
         stream, opts = pipeline.first
         class_for_stream(type, stream).stream(io_stream, opts, &block)
       else
         # Daisy chain multiple streams together
-        last = pipeline.keys.inject(block) { |inner, stream| ->(io) { class_for_stream(type, stream).stream(io, pipeline[stream], &inner) } }
+        last = pipeline.keys.inject(block) { |inner, stream_sym| ->(io) { class_for_stream(type, stream_sym).stream(io, pipeline[stream_sym], &inner) } }
         last.call(io_stream)
       end
     end
   end
 end