class Movie::Streams::Typed::StreamBuilder(T)

Defined in:

movie/streams_typed.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(source_behavior : AbstractBehavior(MessageBase(T))) #

[View source]

Instance Method Detail

def fold(initial : R, reducer : R, T -> R, initial_demand : UInt64 = 0_u64) : RunnableFoldPipeline(T, R) forall R #

[View source]
def to(sink : AbstractBehavior(MessageBase(T)), initial_demand : UInt64 = 0_u64) : RunnablePipeline(T) #

[View source]
def to_collect(initial_demand : UInt64 = 0_u64, channel_capacity : Int32 = 0) : RunnablePipeline(T) #

[View source]
def via(flow : AbstractBehavior(MessageBase(T))) : StreamBuilder(T) #

[View source]