class ProcessExecuter::MonitoredPipe

def monitor_pipe

Other tags:
    Api: - private

Returns:
  • (void) - 
def monitor_pipe
  new_data = pipe_reader.read_nonblock(chunk_size)
rescue IO::WaitReadable
  pipe_reader.wait_readable(0.01)
else
  writers.each { |w| w.write(new_data) }
end