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