module Movie::Streams::Typed::TestSinks

Defined in:

movie/streams/testkit.cr

Class Method Summary

.probe(type : T.class, default_timeout : Time::Span = TESTKIT_DEFAULT_TIMEOUT) : Sink(T, TestSubscriberProbe(T)) forall T

Class Method Detail

def self.probe(type : T.class, default_timeout : Time::Span = TESTKIT_DEFAULT_TIMEOUT) : Sink(T, TestSubscriberProbe(T)) forall T #

[View source]