class Tasker::Pipeline(Input, Output)

• Tasker::Pipeline(Input, Output)
• Reference
• Object

Overview

a lossy pipeline for realtime processing so any outputs are as up to date as possible. This means some results might be ignored at various stages in the pipeline.

Included Modules

• Tasker::Processor(Input)

Defined in:

tasker/pipeline.cr

Constructors

• .new(name : String | Nil = nil, &work : Input -> Output)

Instance Method Summary

• #chain(name : String | Nil = @name, &work : Output -> _)

  push the output of this pipeline task into the input of the next task, if that task is idle

• #chain(task : Pipeline(Output))

  push the output of this pipeline task into the input of the next task, if that task is idle

• #close : Nil

  shutdown processing

• #closed? : Bool

  check if the pipline is running

• #idle? : Bool

  is work being performed currently

• #name : String | Nil

  name of the pipeline

• #process(input : Input) : Bool

  non-blocking send

• #subscribe(&work : Output -> Nil)

  push all the outputs of this task to the subscriber

• #subscribe(subscription : Subscription(Output))

  push all the outputs of this task to the subscriber

• #time : Time::Span

  the time it took to perform the last bit of work

Constructor Detail

Instance Method Detail