module Movie::Streams::Typed

Defined in:

movie/streams/core.cr
movie/streams/testkit.cr
movie/streams_typed.cr

Constant Summary

DEFAULT_BUFFER_SIZE = 16

TESTKIT_DEFAULT_TIMEOUT = 1.second

Class Method Summary

• .manual(type : T.class) : StreamBuilder(T) forall T
• .source(source_behavior : AbstractBehavior(MessageBase(T))) : StreamBuilder(T) forall T

Class Method Detail