Class: Plumbing::Pipeline::Source

Inherits:

Base

• Object
• Base
• Plumbing::Pipeline::Source

Defined in:

lib/plumbing/pipeline/source.rb

Overview

A basic origin pipeline: events pushed in are emitted to its observers.

Constant Summary

Constants included from Actor

Actor::FIBER_KEY, Actor::NotSupported

Instance Attribute Summary

Attributes included from Actor

#worker

Method Summary

Methods inherited from Base

#<<, #initialize

Methods included from Actor

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

Methods included from Actor::Configuration

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

Constructor Details

This class inherits a constructor from Plumbing::Pipeline::Base