struct Movie::Streams::Typed::MaterializedPipeline(T, R)

• Movie::Streams::Typed::MaterializedPipeline(T, R)
• Struct
• Value
• Object

Defined in:

movie/streams_typed.cr

Constructors

• .new(system : ActorSystem(MessageBase(T)), source : ActorRef(MessageBase(T)), sink : ActorRef(MessageBase(T)), completion : Future(R), cancel : -> , out_channel : Channel(T) | Nil = nil)

Instance Method Summary

• #cancel : ->
• #completion : Future(R)
• #out_channel : Channel(T) | Nil
• #sink : ActorRef(MessageBase(T))
• #source : ActorRef(MessageBase(T))
• #system : ActorSystem(MessageBase(T))

Constructor Detail

Instance Method Detail