lib/datapipes/source.rb in datapipes-0.0.3 vs lib/datapipes/source.rb in datapipes-0.0.4

@@ -11,11 +11,11 @@
     include Composable
 
     attr_accessor :pipe
 
     def run_all
-      accumulated ||= [self]
-      accumulated.map {|s| Thread.new { s.run } }
+      @accumulated ||= [self]
+      @accumulated.map {|s| Thread.new { s.run } }
     end
 
     private
 
     def produce(data)