All notable changes to this project will be documented in this file. See Conventional Commits for commit guidelines.
6.0.12 (2021-08-04)
Note: Version bump only for package @thi.ng/rstream
6.0.11 (2021-07-27)
Note: Version bump only for package @thi.ng/rstream
6.0.10 (2021-07-01)
Note: Version bump only for package @thi.ng/rstream
6.0.9 (2021-06-08)
Note: Version bump only for package @thi.ng/rstream
6.0.0 (2021-03-12)
- rstream: fix wrong imports (ae4866a)
- rstream: minor update/revert sub ctor args (c651421)
- rstream: PubSub dispatch & error handling (cca0f34)
- rstream: update failing tests (ae591a1)
- 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)
- rstream: revert to storing child subs in array (014bf20)
- rstream: remove
.subscribe(sub, xform, opts)
signature. Transducer now supplied viaxform
key inopts
(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 anext
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 usingPartial<ISubscriber<T>>
- add
DUMMY
subscriber constant w/ emptynext() {}
- simplify internal
.subscribe()
logic - add
WithErrorHandlerOpts
interface - update
.transform()
&.map()
: add error handling support
5.1.2 (2021-02-22)
- rstream: add auto IDs for bisect/debounce() (89b1def)
5.1.0 (2021-01-22)
- rstream: add CommonOpts for .map() (6324123)
5.0.4 (2020-09-13)
5.0.0 (2020-07-28)
- rstream: fix/update StreamSync type inference (c9d983d)
- 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, useautoObj()
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)
- rstream: add Subscription.map() syntax sugar (a00485e)
4.5.0 (2020-07-02)
- rstream: add reactive(), update readme (e508faa)
4.4.0 (2020-06-14)
- 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)
- rstream: initial default val handling in fromObject() (25117e3)
4.3.0 (2020-05-16)
- rstream: extend fromObject() features/opts (975f74c)
4.2.0 (2020-05-15)
- rstream: add fromObject(), add docs & tests (5e854eb)
- rstream: update fromObject(), add StreamObjOpts, update docs (f3ca3b6)
4.1.0 (2020-05-14)
4.0.8 (2020-05-03)
- rstream: MetaStream close mode handling (2d9e907)
4.0.7 (2020-04-28)
- rstream: subscribe() w/ xform, add test (20ce586)
4.0.3 (2020-04-06)
- rstream: fix Subscription.subscribe() (2a7f6ad)
4.0.0 (2020-03-28)
- rstream: update/rename fromView() (f5df4ab)
- rstream: update/rename fromView(), add fromViewUnsafe()
- fromView() now performs type checking on given path and/or view transform
- existing
fromView()
renamed tofromViewUnsafe()
(this is in line w/ related updates in thi.ng/atom & thi.ng/paths pkgs)
3.0.0 (2019-11-30)
- rstream: add missing timeout() re-export (7062332)
- rstream: update StreamSync.remove(), refactor ctor (d5fd4b4)
- rstream: update readme (4ecdbf9)
- 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)
- 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)
- rstream: preserve const enums (765a9ac)
2.5.0 (2019-07-07)
- rstream: generics & type hints (TS 3.5.2) (eb2e18a)
- rstream: TS strictNullChecks, add assertions (1aad856)
2.4.0 (2019-04-11)
- rstream: add tweenNumber() (cb6d46a)
2.3.8 (2019-04-11)
- rstream: add missing Subscription.deref() return type hint (0ae1243)
2.3.2 (2019-04-02)
2.3.0 (2019-03-21)
- rstream: update clock control for tween(), update docs (65e9c44)
2.2.1 (2019-03-05)
- rstream: add __owner info for MetaStream, update ISubscriber (b5801e9)
2.2.0 (2019-03-03)
- rstream: update MetaStream unsub handling (b2e6e6f)
- rstream: add CloseMode enum, update StreamMerge, StreamSync & opts (f0d53b4)
- rstream: add tween() stream operator (c74a2d0)
2.1.0 (2019-03-01)
- rstream: add metaStream() (bc36005)
2.0.0 (2019-01-21)
- rstream: avoid Subscription ctor to workaround parceljs build issue (d1e275b)
- rstream: disable __State reverse enum lookups (b238a3a)
- update package scripts, outputs, imports in remaining packages (f912a84)
- 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)
- rstream: make maxWorkers optional (46c2882)
- 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)
- rstream:
State
=> const enum (7ac83c6)
1.13.0 (2018-09-22)
1.12.0 (2018-09-08)
- rstream: add merge-only mode for StreamSync, update docs (162aa2d)
1.11.6 (2018-08-27)
- rstream: Fix unbound this in method call expression (34a97b4)
1.11.1 (2018-08-06)
- rstream: add generics for stream() (378772f)
1.11.0 (2018-08-03)
- 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)
- rstream: optimize dispatch if only single child (a59c5c9)
1.9.6 (2018-07-16)
- rstream: emit first value immediately in fromInterval() (9be2018)
1.9.3 (2018-07-09)
- rstream: Fix potential reference error in transduce() (7f2d5dd)
1.9.0 (2018-07-04)
- rstream: add support for event listener opts in
fromEvent()
(d5ac264)
1.8.1 (2018-07-03)
- rstream: unsubscribe on error in transduce() (8c7d937)
1.8.0 (2018-06-21)
- rstream: option to avoid auto-closing
fromInterval()
, add docs (cc5b736)
1.7.3 (2018-06-19)
1.7.0 (2018-05-20)
- rstream: minor update PubSub topic fn return type (cbc600e)
- 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)
- rstream: minor fix StreamSync.addAll() (cc286e1)
1.6.0 (2018-04-24)
- rstream: add owner meta data & IDs for merge/sync inputs (33f55b3)
- rstream: support (re)named StreamSync inputs (b392817)
1.5.0 (2018-04-20)
- 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)
- rstream: add StreamMerge/Sync.removeID() & removeAllIDs() (8bcc287)
1.3.0 (2018-04-15)
- rstream: add Subscription.transform() (2164ddf)
1.2.4 (2018-04-05)
- rstream: correct wrong isString() import (48310a6)
1.2.0 (2018-03-21)
1.1.0 (2018-03-21)
- rstream: bisect() add downstream impl checks, add tests (2ad2f48)
- 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)
- rstream: StreamMerge ctor now accepts an options object
only (
StreamMergeOpts
).
0.9.0 (2018-02-01)
- rstream: add Cache subscription class (ea638be)
0.8.1 (2018-01-31)
- rstream: subscription unhandled error handling (54cd526)
0.8.0 (2018-01-31)
- rstream: add changed predicate for fromAtom(), add tests (d58cf70)
0.7.4 (2018-01-29)
- rstream: fatal recursion w/ error handling (382aa05)
0.7.2 (2018-01-29)
0.7.0 (2018-01-29)
- 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)
- rstream-csp: add new package, remove CSP dep from rstream (e37f6a1)