Method: Fairy::PInject#initialize

Defined in:
lib/fairy/node/p-inject.rb

#initialize(id, processor, bjob, opts, block_source) ⇒ PInject

Returns a new instance of PInject.



13
14
15
16
17
18
19
20
21
22
 
# File 'lib/fairy/node/p-inject.rb', line 13

def initialize(id, processor, bjob, opts, block_source)
  super

  @init_value = :__FAIRY_NO_VALUE__
  if @opts.key?(:init_value)
	@init_value = @opts[:init_value].dc_deep_copy
  end
  @block_source = block_source
#      @inject_proc = @context.create_proc(@block_source)
end