class PipelineCR::Void(T, U)

Overview

End of a sequence, destroying each received package

Defined in:

pipelinecr/void.cr

Constructors

Instance Method Summary

Instance methods inherited from class PipelineCR::Pipeable(T, U)

>>(other : PipelineCR::Pipeable(U, V)) forall V >>, run(input : Channel(T), output : Channel(U), host : Channel(Int32)) run

Constructor Detail

def self.new #

[View source]

Instance Method Detail

def run(input : Channel(T), output : Channel(U), host : Channel(Int32)) #

[View source]