module AggregateStreams

Public Class Methods

start(input_categories, output_category, writer_session: nil, snapshot_interval: nil, **consumer_args, &transform_action) click to toggle source

# File lib/aggregate_streams/aggregate_streams.rb, line 2
def self.start(input_categories, output_category, writer_session: nil, snapshot_interval: nil, **consumer_args, &transform_action)
  settings = {
    :category => output_category,
    :writer_session => writer_session,
    :snapshot_interval => snapshot_interval,
    :transform_action => transform_action
  }

  input_categories.each do |input_category|
    Consumer.start(input_category, output_category: output_category, supplemental_settings: settings, **consumer_args)
  end
end