module Movie::Streams::Typed::Sinks

Defined in:

movie/streams/core.cr

Class Method Summary

• .collect(type : T.class) : Sink(T, Future(Array(T))) forall T
• .fold(type : T.class, initial : R, &reducer : R, T -> R) : Sink(T, Future(R)) forall T, R

Class Method Detail