- 39221db: Fix json serialisation issue when stream contains undefined values
- 035cf6a: add
fromPusher
stream creation method
- 7c566d2: create
onFirst
andonLast
operators
- de16dab: fix batching with timeout and yield-remaining
- 8d3b6be: fix: inconsistency with batch yielding
- 2c8238d: fix: buffered map continuing on stream end
- 70fe273: feat: reject error atom option for
toArray
- 7300858: rename
unknown
toexception
, and deprecate all calls tounknown
- a87c801: fix: incorrect splicing when generating batch
- 2370529: feat: allow batching by bucket
- d9dcc4e: fix: add timeout with
n
option for buffer
- b293d9c:
batch
operator - 784adb4: fix: continue emitting stream items after encountering non-raw item on raw stream
- 87515b3: fix: emit known and unknown errors onto node stream
- e050124: create
bufferedMap
operator
- 8db09c4: Implement
.toReadable()
method for streams
- b8a8ed7: Fix creating streams from arrays with nullish values
- 01dff15: clone array in
fromArray
to prevent mutating original array
- 52f03a1: fix broken types
- ad86792: Add .collect() method to streams
- 3ce4ff3: Implement
fromCallback
for stream creation - 909d5a1: Adds the
cachedFlatMap
operator
- af01d2f: catch unhandled errors in
fromNext
stream creation - 022efea: Improve exported API and generated docs
- 10e211e: Implement .flatten() method on streams
- 31a0db7: alter
flat*
APIs to simplify handlers - ce64206: fix export for CJS
- e9ea819: add
exhaust
stream consumer
- 56147df: fix incorrect stream type for
flatTap
- 27191f4: fix default exports for cjs
- e55d490: create new
ofError
andofUnknown
static methods for creating a stream - e55d490: alter exported API
- 341ef76: add
flatTap
- edd7aad: add Atom types to export
-
0aebf68: add
$.ok
,$.error
, and$.unknown
methods, to simplify creation of single atom streams.restrict items exported from
./atom.ts
, as not everything was required for the public API.
- 22723f5: add
drop
stream transform