Stream Use listeners for events

Static methods

staticinlinefromArray<T>(a:Array<T>):Stream<T>

Constructor

inlinenew()

Methods

atake(d:T ‑> Void, ?compl:Dynamic ‑> Void):Void

inlinedataListener(v:T):Void

inlineendListener():Void

inlineerrorListener(v:Dynamic):Void

map<R>(f:T ‑> R):Stream<R>

putIterable(a:Iterable<T>):Stream<T>

dynamictake(d:T ‑> Void, ?compl:() ‑> Void, ?err:Dynamic ‑> Void):Void