Class: Fairy::PInputVArray

Inherits:

PSingleExportInput

• Object
• PFilter
• PIOFilter
• PSingleExportInput
• Fairy::PInputVArray

Defined in:

lib/fairy/node/p-input-varray.rb

Constant Summary

Constants included from PSingleExportable

Fairy::PSingleExportable::END_OF_STREAM, Fairy::PSingleExportable::ST_EXPORT_FINISH, Fairy::PSingleExportable::ST_WAIT_EXPORT_FINISH

Constants inherited from PIOFilter

Fairy::PIOFilter::ST_WAIT_IMPORT

Constants inherited from PFilter

Fairy::PFilter::END_OF_STREAM, Fairy::PFilter::ST_ACTIVATE, Fairy::PFilter::ST_FINISH, Fairy::PFilter::ST_INIT

Instance Attribute Summary

Attributes included from PSingleExportable

#export

Attributes inherited from PFilter

#IGNORE_EXCEPTION, #id, #log_id, #ntask

Instance Method Summary

• #basic_each(&block) ⇒ Object
• #open(nvarrayplace) ⇒ Object

  def initialize(processor, bjob, opts) super end.

Methods included from PSingleExportable

#initialize, #start, #start_export, #terminate, #wait_export_finish

Methods inherited from PIOFilter

#initialize, #input=

Methods inherited from PFilter

#abort_running, #basic_start, #break_running, #each, #global_break, #global_break_from_other, #handle_exception, #initialize, #key, #key=, #next, #no, #no=, #notice_status, #processor, #start, #start_export, #start_watch_status, #status=, #terminate, #terminate_proc

Instance Method Details

#basic_each(&block) ⇒ Object

# File 'lib/fairy/node/p-input-varray.rb', line 21

def basic_each(&block)
  @array.each &block
end

#open(nvarrayplace) ⇒ Object

def initialize(processor, bjob, opts)

  super
end

# File 'lib/fairy/node/p-input-varray.rb', line 16

def open(nvarrayplace)
  @array = nvarrayplace.ary
  self.no = nvarrayplace.no
end