abstract class PipelineCR::Stage(T, U)

• PipelineCR::Stage(T, U)
• PipelineCR::Pipeable(T, U)
• Reference
• Object

Defined in:

pipelinecr/stage.cr

Constructors

• .new

Class Method Summary

• .*(amount : Int32)

Instance Method Summary

• #on_close
• #on_error(pkg : T, ex : Exception)
• #run(input : Channel(T), output : Channel(U), host : Channel(Int32))
• #task(pkg : T) : U | Nil | Enumerable(U) | Nil

Constructor Detail

Class Method Detail

Instance Method Detail