Gecko [ fernandoquevedodop.com ]

Name	Size	Permission
io.rb	348 B	-rw-r--r--
process.rb	4.92 KB	-rw-r--r--
pump.rb	1.03 KB	-rw-r--r--

Code Editor : pump.rb

module ChildProcess
  module JRuby
    class Pump
      BUFFER_SIZE = 2048

def initialize(input, output)
        @input  = input
        @output = output
        @stop   = false
      end

def stop
        @stop = true
        @thread && @thread.join
      end

def run
        @thread = Thread.new { pump }

self
      end

private

def pump
        buffer = Java.byte[BUFFER_SIZE].new

until @stop && (@input.available == 0)
          read, avail = 0, 0

while read != -1
            avail = [@input.available, 1].max
            avail = BUFFER_SIZE if avail > BUFFER_SIZE
            read = @input.read(buffer, 0, avail)

if read > 0
              @output.write(buffer, 0, read)
              @output.flush
            end
          end

sleep 0.1
        end

@output.flush
      rescue java.io.IOException => ex
        ChildProcess.logger.debug ex.message
        ChildProcess.logger.debug ex.backtrace
      end

end # Pump
  end # JRuby
end # ChildProcess

${this.title}

Code Editor : pump.rb