class Retl::ForkDataCollector

Public Class Methods

new(context) click to toggle source
# File lib/retl/fork_data_collector.rb, line 3
def initialize(context)
  @fork_data = {}

  context._events.listen_to(:fork_data) do |args|
    fork_name = args[:fork_name]
    @fork_data[fork_name] ||= []
    @fork_data[fork_name] << args[:data]
  end
end

Public Instance Methods

take(name) click to toggle source
# File lib/retl/fork_data_collector.rb, line 13
def take(name)
  @fork_data.delete(name)
end