class PipelineCR::Processor(T, U)

Overview

A wrapper around multiple stages processing the same thing to enable easy parallelism, created by multiplying a Stage with a number

Defined in:

pipelinecr/processor.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(stages : Array(Stage(T, U))) #

[View source]

Instance Method Detail

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

[View source]