class Tasker::Subscription(Input)

• Tasker::Subscription(Input)
• Reference
• Object

Included Modules

• Tasker::Processor(Input)

Defined in:

tasker/pipeline.cr

Constructors

• .new(&work : Input -> Nil)

Instance Method Summary

• #close : Nil
• #closed? : Bool

  check if the pipline is running

• #process(input : Input) : Bool

Constructor Detail

Instance Method Detail