module Movie::Streams::Typed::TestSources

Defined in:

Class Method Summary

.probe(type : T.class, buffer_size : Int32 = DEFAULT_BUFFER_SIZE, overflow_strategy : OverflowStrategy = OverflowStrategy::Backpressure, send_timeout : Time::Span = TESTKIT_DEFAULT_TIMEOUT) : Source(T, TestPublisherProbe(T)) forall T

Class Method Detail

def self.probe(type : T.class, buffer_size : Int32 = DEFAULT_BUFFER_SIZE, overflow_strategy : OverflowStrategy = OverflowStrategy::Backpressure, send_timeout : Time::Span = TESTKIT_DEFAULT_TIMEOUT) : Source(T, TestPublisherProbe(T)) forall T #

[View source]