class PipelineCR::Multiplication(T, U)

Overview

A wrapper around multiple pipeables where each package sent to it is forwarded to each pipeable

Defined in:

pipelinecr/multiplication.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(pipeables : Array(Pipeable(T, U))) #

[View source]

Instance Method Detail

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

[View source]