Sha256: 71a3521467a46a545fcac4deb8f104044c914975cc16aef0d6fbcb069fa8e647
Contents?: true
Size: 805 Bytes
Versions: 23
Compression:
Stored size: 805 Bytes
Contents
require 'alephant/logger'
require 'alephant/broker/component'
require 'pmap'
module Alephant
module Broker
module Request
class Batch
include Logger
attr_reader :batch_id, :components, :load_strategy
def initialize(component_factory, env)
logger.info "Request::Batch#initialize: id: #{env.data['batch_id']}"
@batch_id = env.data['batch_id']
@component_factory = component_factory
@components = components_for env
end
private
def components_for(env)
env.data['components'].pmap do |c|
@component_factory.create(
c['component'],
batch_id,
c['options']
)
end
end
end
end
end
end
Version data entries
23 entries across 23 versions & 1 rubygems