CHANGELOG.md

Change Log

All notable changes to this project will be documented in this file. See Conventional Commits for commit guidelines.

6.0.1 (2021-03-17)

Note: Version bump only for package @thi.ng/rstream

6.0.0 (2021-03-12)

Bug Fixes

• rstream: fix wrong imports (ae4866a)
• rstream: minor update/revert sub ctor args (c651421)
• rstream: PubSub dispatch & error handling (cca0f34)
• rstream: update failing tests (ae591a1)

Features

• rstream: #281 update Subscription error/teardown logic (a9e4040)
• rstream: add .transform() error handler opt (#276) (22c6f7c)
• rstream: add generic type for PubSub topics (08adc5f)
• rstream: add ISubscription interface (98edee0)
• rstream: add PubSub.transformTopic() (123e15d)
• rstream: add sidechainPartitionRAF() (a101626)
• rstream: add StreamSource error handling (73023b6)
• rstream: add Sub2 WIP impl (de4149b)
• rstream: further simplify ISubscribable & impls (9e290fe)
• rstream: log error to console (594d806), closes #125 #276
• rstream: update DONE state & teardown logic (a8a8c44)
• rstream: update error handler sig (#281) (015380a)
• rstream: update ITransformable.transform() (fe0eaa9)
• rstream: update PubSub (fa87168)
• rstream: update Sub2, State enum (db0ab34)
• rstream: update Subscription FSM, add/update tests (ea1d0c1)

Performance Improvements

• rstream: revert to storing child subs in array (014bf20)

BREAKING CHANGES

• rstream: remove .subscribe(sub, xform, opts) signature. Transducer now supplied via xform key in opts (or use .transform() instead of .subscribe())

• further simplify Subscription.subscribe() / .transform()
• update Subscription ctor args
• make .subscribe() child subs partial again
• remove temporary & obsolete again DUMMY subscriber
• add docs
• update tests

• rstream: replace transducer only version of PubSub.subscribeTopic() with new .transformTopic(). Similarly to 22c6f7cb2, .subscribeTopic() subs also need to provide at least a next key (for typechecking only)

• add .transformTopic() w/ opt error handling support
• TODO multi-transducer overrides for .transformTopic()

• rstream: update ISubscribable contract, remove transducer only version of .subscribe(), MUST provide dummy sub w/ transducer OR (better) use .transform() instead (which also more clearly communicates intention...)

• another breaking change side effect for .subscribe(): next() handlers MUST be provided now in first arg (child sub), this is NOT because they're mandatory now, but TS won't be able to correctly infer arg types when using Partial<ISubscriber<T>>
• add DUMMY subscriber constant w/ empty next() {}
• simplify internal .subscribe() logic
• add WithErrorHandlerOpts interface
• update .transform() & .map(): add error handling support

5.1.2 (2021-02-22)

Bug Fixes

• rstream: add auto IDs for bisect/debounce() (89b1def)

5.1.0 (2021-01-22)

Features

• rstream: add CommonOpts for .map() (6324123)

5.0.4 (2020-09-13)

Bug Fixes

• rstream: update PubSub.subscribeTopic(), fix #248 (3e2240a)

5.0.0 (2020-07-28)

Features

• rstream: fix/update StreamSync type inference (c9d983d)

BREAKING CHANGES

• rstream: better StreamSync generics handling/inference & updated StreamSyncOpts

• src opt (input sources) MUST be given as object now (specifying inputs as array not supported anymore, use autoObj() from transducers package to convert array into auto-labeled object)
• update StreamSync inference rules to better determine result type
• simplify .addAll()
• generics now usually don't need to manually be specified anymore (with some exceptions)
• update tests

4.6.0 (2020-07-08)

Features

• rstream: add Subscription.map() syntax sugar (a00485e)

4.5.0 (2020-07-02)

Features

• rstream: add reactive(), update readme (e508faa)

4.4.0 (2020-06-14)

Features

• rstream: add debounce() sub & tests (9c53bb4)
• rstream: add emitLast metastream option (1073735)
• rstream: add error handling for transducer phase (609424e)

4.3.1 (2020-05-16)

Bug Fixes

• rstream: initial default val handling in fromObject() (25117e3)

4.3.0 (2020-05-16)

Features

• rstream: extend fromObject() features/opts (975f74c)

4.2.0 (2020-05-15)

Features

• rstream: add fromObject(), add docs & tests (5e854eb)
• rstream: update fromObject(), add StreamObjOpts, update docs (f3ca3b6)

4.1.0 (2020-05-14)

Features

• rstream: #221, update StreamSync input removal (52ee040)

4.0.8 (2020-05-03)

Bug Fixes

• rstream: MetaStream close mode handling (2d9e907)

4.0.7 (2020-04-28)

Bug Fixes

• rstream: subscribe() w/ xform, add test (20ce586)

4.0.3 (2020-04-06)

Bug Fixes

• rstream: fix Subscription.subscribe() (2a7f6ad)

4.0.0 (2020-03-28)

Features

• rstream: update/rename fromView() (f5df4ab)

BREAKING CHANGES

• rstream: update/rename fromView(), add fromViewUnsafe()

• fromView() now performs type checking on given path and/or view transform
• existing fromView() renamed to fromViewUnsafe() (this is in line w/ related updates in thi.ng/atom & thi.ng/paths pkgs)

3.0.0 (2019-11-30)

Bug Fixes

• rstream: add missing timeout() re-export (7062332)
• rstream: update StreamSync.remove(), refactor ctor (d5fd4b4)

Documentation

• rstream: update readme (4ecdbf9)

Features

• rstream: add back pressure opts to StreamSyncOpts & ForkJoinOpts (e236987)
• rstream: add CommonOpts support for ISubscribable & ITransformable (0a70b90)
• rstream: add forkBuffer/joinBuffer HOFs, add docs (a35c8e8)
• rstream: add forkJoin() parallel worker processing (da03722)
• rstream: add ITransformable interface, minor updates (da52b98)
• rstream: add Subscription.done() error handling (c911006)
• rstream: add/update fork/joinBuffer generics, optimize (8f0c55c)
• rstream: initial work on #74, #81, #91, #92, add stream opts (e770469)
• rstream: update args for various fromXXX() stream factories (b466ebc)
• rstream: update sidechainPartition/Toggle and timeout (898eb53)
• rstream: update Stream cancel & reset behavior for CloseMode.NEVER (250dfe1)

BREAKING CHANGES

• rstream: document new stream/sub config opts in readme
• rstream: update stream factories to use options object args

• fromAtom
• fromInterval
• fromIterable
• fromView
• fromWorker

2.5.3 (2019-08-16)

Bug Fixes

• rstream: preserve const enums (765a9ac)

2.5.0 (2019-07-07)

Bug Fixes

• rstream: generics & type hints (TS 3.5.2) (eb2e18a)
• rstream: TS strictNullChecks, add assertions (1aad856)

Features

• rstream: add fromDOMEvent() (6e3fec8)
• rstream: enable TS strict compiler flags (refactor) (d796e21)

2.4.0 (2019-04-11)

Features

• rstream: add tweenNumber() (cb6d46a)

2.3.8 (2019-04-11)

Bug Fixes

• rstream: add missing Subscription.deref() return type hint (0ae1243)

2.3.2 (2019-04-02)

Bug Fixes

• rstream: fix #80 update StreamSource alias (f7b9fbd)

2.3.0 (2019-03-21)

Features

• rstream: update clock control for tween(), update docs (65e9c44)

2.2.1 (2019-03-05)

Bug Fixes

• rstream: add __owner info for MetaStream, update ISubscriber (b5801e9)

2.2.0 (2019-03-03)

Bug Fixes

• rstream: update MetaStream unsub handling (b2e6e6f)

Features

• rstream: add CloseMode enum, update StreamMerge, StreamSync & opts (f0d53b4)
• rstream: add tween() stream operator (c74a2d0)

2.1.0 (2019-03-01)

Features

• rstream: add metaStream() (bc36005)

2.0.0 (2019-01-21)

Bug Fixes

• rstream: avoid Subscription ctor to workaround parceljs build issue (d1e275b)
• rstream: disable __State reverse enum lookups (b238a3a)

Build System

• update package scripts, outputs, imports in remaining packages (f912a84)

BREAKING CHANGES

• enable multi-outputs (ES6 modules, CJS, UMD)

• build scripts now first build ES6 modules in package root, then call scripts/bundle-module to build minified CJS & UMD bundles in /lib
• all imports MUST be updated to only refer to package level (not individual files anymore). tree shaking in user land will get rid of all unused imported symbols

1.14.0 (2018-11-24)

Bug Fixes

• rstream: make maxWorkers optional (46c2882)

Features

• rstream: add StreamSync.getSources() / getSourceForID() (ef0fe42)
• rstream: add support multiple workers in Tunnel & TunnelOpts (67a5b10)
• rstream: add worker tunnel() sub (4750e79)

1.13.2 (2018-09-24)

Performance Improvements

• rstream: State => const enum (7ac83c6)

1.13.0 (2018-09-22)

Features

• rstream: add trigger() generics (288b68d)
• rstream: add trigger() utility stream (929c6f4)

1.12.0 (2018-09-08)

Features

• rstream: add merge-only mode for StreamSync, update docs (162aa2d)

1.11.6 (2018-08-27)

Bug Fixes

• rstream: Fix unbound this in method call expression (34a97b4)

1.11.1 (2018-08-06)

Bug Fixes

• rstream: add generics for stream() (378772f)

1.11.0 (2018-08-03)

Features

• rstream: add stream() & subscription() factories, add/update docs (e97aac0)
• rstream: update StreamSync to use reset: false by default, update docs (55499cc)

1.10.0 (2018-07-20)

Features

• rstream: Add a timeout() subscription (aa55973)
• rstream: add reset option for timeout() (cd751fb)

Performance Improvements

• rstream: optimize dispatch if only single child (a59c5c9)

1.9.6 (2018-07-16)

Bug Fixes

• rstream: emit first value immediately in fromInterval() (9be2018)

1.9.3 (2018-07-09)

Bug Fixes

• rstream: Fix potential reference error in transduce() (7f2d5dd)

1.9.0 (2018-07-04)

Features

• rstream: add support for event listener opts in fromEvent() (d5ac264)

1.8.1 (2018-07-03)

Bug Fixes

• rstream: unsubscribe on error in transduce() (8c7d937)

1.8.0 (2018-06-21)

Features

• rstream: option to avoid auto-closing fromInterval(), add docs (cc5b736)

1.7.3 (2018-06-19)

1.7.0 (2018-05-20)

Bug Fixes

• rstream: minor update PubSub topic fn return type (cbc600e)

Features

• rstream: re-implement bisect() using PubSub, update tests (846aaf9)
• rstream: update resolve(), update subscribe() overrides (23fdd39)

1.6.14 (2018-05-14)

1.6.1 (2018-04-25)

Bug Fixes

• rstream: minor fix StreamSync.addAll() (cc286e1)

1.6.0 (2018-04-24)

Features

• rstream: add owner meta data & IDs for merge/sync inputs (33f55b3)

Performance Improvements

• rstream: support (re)named StreamSync inputs (b392817)

1.5.0 (2018-04-20)

Features

• rstream: add PubSub, add ISubscribableSubscriber, remove cache() (27a098d)
• rstream: allow arbitrary PubSub topic vals, add @thi.ng/associative dep (ba10907)

1.4.0 (2018-04-16)

Features

• rstream: add StreamMerge/Sync.removeID() & removeAllIDs() (8bcc287)

1.3.0 (2018-04-15)

Features

• rstream: add Subscription.transform() (2164ddf)

1.2.4 (2018-04-05)

Bug Fixes

• rstream: correct wrong isString() import (48310a6)

1.2.0 (2018-03-21)

Features

• rstream: update error handling, add @thi.ng/api dep (1ce7054)

1.1.0 (2018-03-21)

Bug Fixes

• rstream: bisect() add downstream impl checks, add tests (2ad2f48)

Features

• rstream: add fromView(), update fromAtom() docs, update re-exports (41bb385)
• rstream: add IDeref impl for Subscription (907d599)
• rstream: add merge()/sync() ctor wrappers (1fee7d5)
• rstream: add StreamSync (791a993)
• rstream: add transduce(), update re-exports (eec56de)
• rstream: fix #6 update StreamMerge to support transduced input streams (8026409)
• rstream: Subscription stores last value and passes to new subs (6b87bca)
• rstream: update Sidechain*.next(), add unsubscribe() (d18a115)
• rstream: update Subscription.unsubscribe() (01a751e)

1.0.22 (2018-03-19)

1.0.0 (2018-02-18)

Features

• rstream: fix #8, support infinite StreamMerge's, update ctor (4942e2e)

BREAKING CHANGES

• rstream: StreamMerge ctor now accepts an options object only (StreamMergeOpts).

0.9.0 (2018-02-01)

Features

• rstream: add Cache subscription class (ea638be)

0.8.1 (2018-01-31)

Bug Fixes

• rstream: subscription unhandled error handling (54cd526)

0.8.0 (2018-01-31)

Features

• rstream: add changed predicate for fromAtom(), add tests (d58cf70)

0.7.4 (2018-01-29)

Bug Fixes

• rstream: fatal recursion w/ error handling (382aa05)

0.7.2 (2018-01-29)

Bug Fixes

• rstream: fix #1 update fromPromise(), add test (822b297)

0.7.0 (2018-01-29)

Features

• rstream: add atom dep, add fromAtom() & docs (ca3994a)
• rstream: add fromPromises(), add docs (55ba0e1)
• rstream: add trace() error handler (2247f72)

0.6.0 (2018-01-28)

Features

• rstream-csp: add new package, remove CSP dep from rstream (e37f6a1)