Merge pull request #40 from softace/softace/interactive_streams

Making the streams interactive for jruby

lib/childprocess/jruby/process.rb

@@ -90,6 +90,10 @@ def setup_io
         if duplex?
           stdin = @process.getOutputStream.to_io
           stdin.sync = true
+          stdin.instance_variable_set(:@java_stream, @process.getOutputStream)
+          def stdin.__flushit; @java_stream.flush; end #The stream provided is a BufferedeOutputStream, so we have to flush it to make the bytes flow to the process
+          def stdin.flush; super; self.__flushit; end
+          def stdin.puts(*args); super(*args); self.__flushit; end
 
           io._stdin = stdin
         else

spec/io_spec.rb

@@ -98,6 +98,40 @@
     end
   end
 
+  it "can write to stdin interactively if duplex = true" do
+    process = cat
+
+    out = Tempfile.new("duplex")
+    out.sync = true
+
+    out_receiver = File.open(out.path, "rb")
+    begin
+      process.io.stdout = out
+      process.io.stderr = out
+      process.duplex = true
+
+      process.start
+      process.io.stdin.puts "hello"
+      sleep 0.1
+      out_receiver.read.should == "hello\n"
+      process.io.stdin.puts "new"
+      sleep 0.1
+      out_receiver.read.should == "new\n"
+      process.io.stdin.write "world\n"
+      process.io.stdin.flush
+      sleep 0.1
+      out_receiver.read.should == "world\n"
+      process.io.stdin.close
+      process.poll_for_exit(exit_timeout)
+
+      out_receiver.rewind
+      out_receiver.read.should == "hello\nnew\nworld\n"
+     ensure
+      out_receiver.close
+      out.close
+    end
+  end
+
   #
   # this works on JRuby 1.6.5 on my Mac, but for some reason
   # hangs on Travis (running 1.6.5.1 + OpenJDK).