debugging

lib/pipeline.rb

@@ -31,15 +31,8 @@ class Pipeline
   def transform_all(&transformation)
     old_op = @op
     @op = lambda {|nxt| old_op.call(lambda {|fp| 
-      IO.pipe {|r, w|
-        task = Thread.new(fp, w, transformation) { |fp, w, transformation|
-          w.write(transformation.call(fp.read))
-          w.close_write
-        }
-        ret = nxt.call(r)
-        task.join()
-        ret
-      }
+      data = transformation.call(fp.read)
+      nxt.call(StringIO.new(data))
     })}
   end