struct Movie::Streams::Typed::RunnablePipeline(T)

• Movie::Streams::Typed::RunnablePipeline(T)
• Struct
• Value
• Object

Defined in:

Constructors

• .new(source_behavior : AbstractBehavior(MessageBase(T)), flows : Array(AbstractBehavior(MessageBase(T))), sink_behavior : AbstractBehavior(MessageBase(T)), initial_demand : UInt64 = 0_u64, out_channel : Channel(T) | Nil = nil, pre_cancel : Proc(Nil) | Nil = nil)

Instance Method Summary

• #run(system : ActorSystem(MessageBase(T))) : MaterializedPipeline(T, Nil)

Constructor Detail

Instance Method Detail