class Tresse::Batch
Attributes
completed[R]
error[R]
group[R]
map_index[R]
value[RW]
Public Class Methods
new(group, block_or_group)
click to toggle source
# File lib/tresse.rb, line 86 def initialize(group, block_or_group) @group = group @bog = block_or_group @map_index = -1 @value = nil @completed = false end
Public Instance Methods
complete()
click to toggle source
# File lib/tresse.rb, line 114 def complete @completed = true end
error=(err)
click to toggle source
# File lib/tresse.rb, line 119 def error=(err) @error = err @group.send(:receive, self) end
map(type, block)
click to toggle source
# File lib/tresse.rb, line 107 def map(type, block) r = Tresse.call_block(block, [ @value, self ]) @value = r if type == :map end
process()
click to toggle source
# File lib/tresse.rb, line 96 def process @map_index += 1 @group.send(:receive, self) end
source()
click to toggle source
# File lib/tresse.rb, line 102 def source @value = Tresse.call_block(@bog, [ group ] + [ nil ] * 7) end