class PipelineCR::Pipeline(T, U)

Defined in:

pipelinecr/pipeline.cr

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new(pipeable : Pipeable(T, U)) #

[View source]

Class Method Detail

def self.build(&) #

[View source]

Instance Method Detail

def <<(packages : Enumerable(T)) #

[View source]
def <<(package : T) #

[View source]
def close #

[View source]
def finish #

[View source]
def on_receive(&block : U -> Nil) #

[View source]
def receiver=(array : Array(U)) #

[View source]