class PipelineCR::Seperation(T, U)
- PipelineCR::Seperation(T, U)
- PipelineCR::Pipeable(T, U)
- Reference
- Object
Overview
A wrapper around multiple pipeables where each package sent to the first pipeable that accepts it
Defined in:
pipelinecr/seperation.crConstructors
- .new(pipeables : Array(Tuple(Pipeable(T, U), Proc(T, Bool))), fallback : Pipeable(T, U) | Nil = nil)
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(pipeables : Array(Tuple(Pipeable(T, U), Proc(T, Bool))), fallback : Pipeable(T, U) | Nil = nil)
#