An implementation of concat that buffers all source stream events
Marble diagram:
--1--2---3---4-|
-a--b-c--d-|
--------X---------Y---------Z-
concat
--1--2---3---4-abcdXY-------Z-
This is inspired by RxJS's concat as documented at http://rxmarbles.com/#concat and behaves differently than xstream's concat as discussed in https://github.com/staltz/xstream/issues/170.
Drops duplicate values in a stream.
Marble diagram:
-1-1-1-2-4-3-3-4--
dropDuplicates
-1-----2-4-3------
Each value must be uniquely identified by a string given by valueToKey(value).
Internally this maintains a set of keys that have been processed already, i.e. memory consumption and Set lookup times should be considered when using this function.
Listens to stream, collects one event and revolves.
Rejects if stream completes before one event was fired.
Emits one event for each list element as soon as the promise resolves
Listens to stream and collects events. When count events are collected,
the promise resolves with an array of events.
Rejects if stream completes before count events are collected.
Generated using TypeDoc
The type that fits into Stream.compose() with input stream and output stream of the same type.