lib/datapipes.rb in datapipes-0.0.4 vs lib/datapipes.rb in datapipes-0.1.0

@@ -4,10 +4,11 @@
 require 'datapipes/sink'
 require 'datapipes/pipe'
 require 'datapipes/version'
 
 class Datapipes
+  # TODO: optional tube and pipe
   def initialize(source, tube, sink, pipe)
     @source = source
     @tube = tube
     @sink = sink
     @pipe = pipe
@@ -32,10 +33,10 @@
   def run_comsumer
     Thread.new do
       loop do
         break if resource_ended? && @pipe.empty?
 
-        data = @tube.run_all(@pipe.pull)
+        data = @tube.run(@pipe.pull)
         @sink.run_all(data)
       end
       Thread.current.kill
     end
   end