class

Bus::Pipeline(T)

Inherits Channel < Iterator < Enumerable < Reference < Object

A pipeline is just a channel with an extra origin tag that can be used to uniquely identify this particular pipeline.

Constructors

new(capacity = 0, origin : String = CSUUID.new.to_s)
Source

Instance methods

<=>(val)
Source
clear

Clear everything that is currently in the pipeline.

Source
origin
Source
origin=(origin : String)
Source
size

Get a count of how many items are currently in the pipeline.

Source