Class: RIO::Cmd::FibPipeProc

Inherits:

FromProc

• Object
• FibPipe
• From
• FromProc
• RIO::Cmd::FibPipeProc

Defined in:

lib/rio/fibpipe.rb

Constant Summary

Constants inherited from FromProc

RIO::Cmd::FromProc::BUF_LEN

Instance Attribute Summary

Attributes inherited from From

#pipe

Attributes inherited from FibPipe

#fib, #source

Instance Method Summary

• #_fiber_init(trail) ⇒ Object
• #initialize(*args) ⇒ FibPipeProc constructor

  A new instance of FibPipeProc.

Methods inherited from FromProc

#get, #source_wait

Methods inherited from From

#_create_output_fiber, #process_loop

Methods inherited from FibPipe

#dest_report_data_done, #dest_report_new_data, #dest_wait_for_reader, #fiber_yield, #resume, #source_resume

Constructor Details

#initialize(*args) ⇒ FibPipeProc

Returns a new instance of FibPipeProc.

# File 'lib/rio/fibpipe.rb', line 242

def initialize(*args)
  super(IO.popen(*args))
  @to_proc = ToProc.new(data.in)
end

Instance Method Details

#_fiber_init(trail) ⇒ Object

# File 'lib/rio/fibpipe.rb', line 246

def _fiber_init(trail)
  trail.unshift(@to_proc)
  super(trail)
end