Class: Plumbing::Pipeline::Junction

Inherits:

Base

• Object
• Base
• Plumbing::Pipeline::Junction

Defined in:

lib/plumbing/pipeline/junction.rb

Overview

Fan-in: merges several sources into one, re-emitting every event from each.

Constant Summary

Constants included from Actor

Actor::FIBER_KEY, Actor::NotSupported

Instance Attribute Summary

Attributes included from Actor

#worker

Instance Method Summary

• #initialize(*sources) ⇒ Junction constructor

  A new instance of Junction.

Methods inherited from Base

#<<

Methods included from Actor

#after, #cancel_deferred, #current_sender, #current_senders, included

Methods included from Actor::Configuration

#register, #selected_worker_type, #uses, #worker_for, #worker_types, #workers

Constructor Details

#initialize(*sources) ⇒ Junction

Returns a new instance of Junction.

# File 'lib/plumbing/pipeline/junction.rb', line 9

def initialize(*sources)
  super()
  sources.each { |source| chain(source) { true } }
end