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

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

Defined in:

movie/streams_typed.cr

Constructors

.new(source_behavior : AbstractBehavior(MessageBase(T)), flows : Array(AbstractBehavior(MessageBase(T))), initial : R, reducer : R, T -> R, initial_demand : UInt64 = 0_u64)

Instance Method Summary

#run(system : ActorSystem(MessageBase(T))) : MaterializedPipeline(T, R)

Constructor Detail

def self.new(source_behavior : AbstractBehavior(MessageBase(T)), flows : Array(AbstractBehavior(MessageBase(T))), initial : R, reducer : R, T -> R, initial_demand : UInt64 = 0_u64) #

[View source]

Instance Method Detail

def run(system : ActorSystem(MessageBase(T))) : MaterializedPipeline(T, R) #

[View source]