module Movie::Streams::Typed::Sources

Defined in:

movie/streams/core.cr

Class Method Summary

Class Method Detail

def self.manual(type : T.class, buffer_size : Int32 = DEFAULT_BUFFER_SIZE, overflow_strategy : OverflowStrategy = OverflowStrategy::Backpressure) : Source(T, ManualSourceControl(T)) forall T #

[View source]