class Bus::Pipeline(T)

Overview

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

Defined in:

bus/pipeline.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(capacity = 0, origin : String = CSUUID.new.to_s) #

[View source]

Instance Method Detail

def <=>(val) #

[View source]
def clear #

Clear everything that is currently in the pipeline.


[View source]
def origin : String #

[View source]
def origin=(origin : String) #

[View source]
def size : Int32 #

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


[View source]