0
@@ -4,10 +4,11 @@ require "ropen"
0
 # TODO: would halting the callback chain make any sense?
0
 
0
 class Ropen::Events
0
-  attr_reader :callbacks
0
+  attr_reader :callbacks, :output
0
   
0
   def initialize
0
     @callbacks = []
0
+    @output = ""
0
   end
0
   
0
   def on_output(&block)
0
@@ -18,6 +19,7 @@ class Ropen::Events
0
     @thread = Thread.new do
0
       until stream.eof?
0
         data = stream.readpartial(1024)
0
+        @output << data
0
         @callbacks.each do |e|
0
           e.call(data)
0
         end

0
@@ -43,6 +43,7 @@ describe Ropen::Events do
0
     
0
     @events.run(@stream)
0
     @events.finish
0
+    @events.output.should == "blahblee"
0
     
0
     output.transpose.last.should == ["blah", "blah", "blee", "blee"]
0
   end