module Movie::Streams::Typed::Flows

Defined in:

Class Method Summary

.map(input_type : In.class, output_type : Out.class, buffer_size : Int32 = DEFAULT_BUFFER_SIZE, overflow_strategy : OverflowStrategy = OverflowStrategy::Backpressure, &transform : In -> Out) : Flow(In, Out, NotUsed) forall In, Out

Class Method Detail

def self.map(input_type : In.class, output_type : Out.class, buffer_size : Int32 = DEFAULT_BUFFER_SIZE, overflow_strategy : OverflowStrategy = OverflowStrategy::Backpressure, &transform : In -> Out) : Flow(In, Out, NotUsed) forall In, Out #

[View source]