class Movie::Streams::Typed::Flow(In, Out, Mat)

• Movie::Streams::Typed::Flow(In, Out, Mat)
• Reference
• Object

Overview

Reusable one-in/one-out flow blueprint. In and Out may differ.

Defined in:

movie/streams/core.cr

Constructors

• .new(&block : AbstractActorSystem, StageChannel(In) -> Materialization(Out, Mat))

Instance Method Summary

• #materialize(system : AbstractActorSystem, inlet : StageChannel(In)) : Materialization(Out, Mat)

  Internal materialization hook used by composition.

• #via(flow : Flow(Out, Next, NextMat)) : Flow(In, Next, Mat) forall Next, NextMat
• #via_mat(flow : Flow(Out, Next, NextMat), &combine : Mat, NextMat -> Combined) : Flow(In, Next, Combined) forall Next, NextMat, Combined

Constructor Detail

Instance Method Detail