Class: Plumbing::Pipe::Junction

Inherits:

Plumbing::Pipe

• Object
• Plumbing::Pipe
• Plumbing::Pipe::Junction

Defined in:

lib/plumbing/pipe/junction.rb

Overview

A pipe that filters events from a source pipe

Instance Method Summary

• #initialize(*sources) ⇒ Junction constructor

  Chain multiple sources to this pipe.

Methods inherited from Plumbing::Pipe

#add_observer, #is_observer?, #notify, #remove_observer, #shutdown

Methods included from Actor

#in_context?, included, #safely, #stop, timeout, transporter

Constructor Details

#initialize(*sources) ⇒ Junction

Chain multiple sources to this pipe

Parameters:

• sources (Array<Plumbing::Observable>) —

  the sources which will be joined and relayed

# File 'lib/plumbing/pipe/junction.rb', line 6

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