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