new (init:Message<T> ‑> Void ‑> Void ‑> Void)
alternate (other:Stream<T>):Stream<T>
always (handler:Void ‑> Void):Process<T>
appendTo (other:Stream<T>):Stream<T>
collect ():Stream<Array<T>>
collectAll ():Stream<Array<T>>
comp (compare:T ‑> T ‑> Bool):Stream<T>
concat (other:Stream<T>):Stream<T>
debounce (ms:Int):Stream<T>
delayed (ms:Int):Stream<T>
distinct (?equality:T ‑> T ‑> Bool):Stream<T>
done (handler:Void ‑> Void):Process<T>
effect (handler:T ‑> Void):Stream<T>
failure (handler:Error ‑> Void):Process<T>
filter (predicate:T ‑> Bool):Stream<T>
filterFuture (predicate:T ‑> Future<Bool>):Stream<T>
filterMap<B> (predicate:T ‑> Option<B>):Stream<B>
filterMapFuture<B> (predicate:T ‑> Future<Option<B>>):Stream<B>
filterMapPromise<B> (predicate:T ‑> Promise<Option<B>>):Stream<B>
filterPromise (predicate:T ‑> Promise<Bool>):Stream<T>
first ():Stream<T>
flatMap<B> (handler:T ‑> Stream<B>):Stream<B>
fold (handler:T ‑> T ‑> T):Stream<T>
last ():Stream<T>
log (?prefix:String, ?pos:PosInfos):Stream<T>
logMessage (?prefix:String, ?pos:PosInfos):Stream<T>
map<B> (handler:T ‑> B):Stream<B>
merge (other:Stream<T>):Stream<T>
message (handler:Message<T> ‑> Void):Process<T>
next (handler:T ‑> Void):Process<T>
pair<B> (other:Stream<B>):Stream<Tuple<T, B>>
reduce<Acc> (handler:Acc ‑> T ‑> Acc, acc:Acc):Stream<Acc>
sampledBy<B> (other:Stream<B>):Stream<Tuple<T, B>>
samplerOf<B> (other:Stream<B>):Stream<Tuple<B, T>>
scan<Acc> (acc:Acc, handler:Acc ‑> T ‑> Acc):Stream<Acc>
skip (qt:Int):Stream<T>
skipFirst ():Stream<T>
skipFromEnd (qt:Int):Stream<Null<T>>
skipLast ():Stream<Null<T>>
skipUntil (predicate:T ‑> Bool):Stream<T>
slidingWindow (minSize:Int, maxSize:Int):Stream<ReadonlyArray<T>>
spaced (ms:Int):Stream<T>
take (qt:Int):Stream<T>
takeAt (index:Int):Stream<T>
takeUntil (predicate:T ‑> Bool):Stream<T>
unique (set:Set<T>):Stream<T>
window (size:Int):Stream<ReadonlyArray<T>>
zip<B> (other:Stream<B>):Stream<Tuple<T, B>>
staticcancellable<T> (init:Subject<T> ‑> Void ‑> Void ‑> Void ‑> Void):Stream<T>
staticcreate<T> (init:Subject<T> ‑> Void):Stream<T>
staticdelay<T> (ms:Int):Stream<T>
staticdelayValue<T> (ms:Int, value:T):Stream<T>
staticempty<T> ():Stream<T>
staticerror<T> (err:Error):Stream<T>
staticfail<T> (msg:String, ?pos:PosInfos):Stream<T>
staticframe ():Stream<Float>
staticiterator<T> (values:Iterator<T>):Stream<T>
staticpoll<T> (ms:Int, f:Void ‑> T):Stream<T>
staticrepeat (ms:Int):Stream<Unit>
staticrepeatValue<T> (ms:Int, value:T):Stream<T>
staticvalue<T> (value:T):Stream<T>
staticvalues<T> (values:ReadonlyArray<T>):Stream<T>