class Movie::Streams::Typed::Source(Out, Mat)

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

Overview

Reusable source blueprint with an output element type and a materialized-value type.

Defined in:

movie/streams/core.cr

Constructors

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

Instance Method Summary

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

  Internal materialization hook used by composition.

• #to(sink : Sink(Out, SinkMat)) : RunnableGraph(SinkMat) forall SinkMat
• #to_mat(sink : Sink(Out, SinkMat), &combine : Mat, SinkMat -> Combined) : RunnableGraph(Combined) forall SinkMat, Combined
• #via(flow : Flow(Out, Next, FlowMat)) : Source(Next, Mat) forall Next, FlowMat
• #via_mat(flow : Flow(Out, Next, FlowMat), &combine : Mat, FlowMat -> Combined) : Source(Next, Combined) forall Next, FlowMat, Combined

Constructor Detail

Instance Method Detail