multitude

Comprehensive streams for push and pull.

Install

npm install multitude

Documentation

See documentation.

0.0.7 (2021-07-01)

Bug Fixes

• deps: update type-core dependency (5a0ce49)

Features

• push: adds value option to Multicast (5bbfc3b)

0.0.6 (2021-06-11)

Bug Fixes

• push: fix filter operator types (41e7bf9)

0.0.5 (2020-12-22)

Bug Fixes

• push: fixes take operator leak (ce10ecc)

0.0.4 (2020-12-20)

Code Refactoring

• push: renames changes operator as compare (e8c0671)

Features

• push: adds start operator (51de47f)

BREAKING CHANGES

• push: The changes operator is now exported as compare

0.0.3 (2020-12-18)

Bug Fixes

• push: fixes mergeMap operator types (53a9fd4)

Features

• push: adds start operator (d34bc11)

0.0.2 (2020-12-15)

Features

• push: adds first consume operator (94a0b30)

0.0.1 (2020-12-12)

Bug Fixes

• definitions: fixes push definitions (78b69e5)
• definitions: fixes push definitions (625d4a6)
• deps: updates dependencies (e4a187f)
• deps: updates dependencies (887d284)
• deps: updates type-core version (8d8f67c)
• helpers: fixes FailureManager (82eebf3)
• push: fixes Broker promise methods when passed via Hearback.start (05da612)
• push: fixes circular dependencies (ef071be)
• push: fixes from creation function (cfcb0eb)
• adds missing dependencies (ecb6a8c)
• push: fixes circular dependencies (b735828)
• push: fixes PushableStream (7ca929b)
• aligns PushStream.from and reference Observable.from with Observable spec (a83dbc6)
• deps: fixes dangling and pending dependencies (d6e7dd1)
• PushStream: fixes consumption as a regular Stream (f8b737b)
• PushStream: fixes errors blocking teardown's retrieval/execution, adds safe mode (9d52424)
• PushStream: fixes Subscription resolution before Subscriber has finalized executing (b8d78f5)
• PushStream: raises error when Talkback.error() throws with a synchronous final error (abc523a)
• PushStream: Subscription.closed is true as soon as the consumer Talkback is closed (91d8fc4)
• streams: fixes Stream (cef2671)
• ensures methods are not accessed twice for the same SubscriptionObserver/Talkback call (3e021d3)
• fixes Observable.subscribe (4d8cf95)
• fixes SubscriptionObserver.complete (5106de6)
• fixes SubscriptionObserver.error (198db82)
• fixes SubscriptionObserver.next (0b9ad99)

Features

• pull: implements Pullable.from; adds Pull.LikeConstructor, Pull.Convertible, Pull.Like definitions; adds pull type guards (3bf476d)
• push: adds catches operator (095c13b)
• push: adds changes operator (dba1845)
• push: adds combine creation function (be92b7a)
• push: adds connect operator (1e0fa15)
• push: adds ConnectableStream (eaf0c51)
• push: adds creators fromEvent, defer, throws (28c4b12)
• push: adds debounce operator (42e8c49)
• push: adds delay operator (071c266)
• push: adds distinct operator (cb7801d)
• push: adds extract operator (a6d2120)
• push: adds filter operator (f658af0)
• push: adds group operator (87e66ac)
• push: adds interval (b7e46ee)
• push: adds map operator (4c00023)
• push: adds merge (ce060a6)
• push: adds mergeMap operator (3f5f6d8)
• push: adds Multicast push definition and class; refactors Subject class and connect, share operators (3075b55)
• push: adds omit, pick operators (3254d45)
• push: adds onCloseSubscription to Hooks; adds Hooks class; improves hooks handling (7aa1835)
• push: adds react hooks utils (e64345f)
• push: adds replay for PushableStream; removes ConnectableStream (a78fcc6)
• push: adds Router; deletes Forwarder; implements PushableStream, intercept w/ Router (a939047)
• push: adds share operator (549f567)
• push: adds skip operator (5045ec0)
• push: adds take operator (cedf7d4)
• push: adds tap operator (3854710)
• push: adds timestamp operator (9b1186b)
• push: adds trail operator (308d695)
• push: deprecates Subject.start in favor or Subject.of (d18c20b)
• exports compliant Observable w/ extensions; removes PushStream; renames PushableStream to Subject; renames PullableStream to Pullable (76d59e5)
• creation: adds combine (06ffbc5)
• definitions: adds definitions for iterables (fead788)
• iterables: implements PullStream (71b5178)
• observable: adds Observable implementation (0b9f0da)
• operators: adds changes (d1e23e1)
• operators: adds match (8491c61)
• operators: adds omit (26de254)
• operators: adds pick (9c50989)
• operators: adds select (afac894)
• push: adds operate and forward utils (ac17f47)
• push: adds switchMap operator (7dcd637)
• push: adds terminate to PushStream Hearback (8993f22)
• push: adds transform and intercept utils, redesigns operate, replaces forward with Forwarder (7028e81)
• push: exports of, from as functions (38083f5)
• push: exports operators (74d48a4)
• push: from creates from PromiseLike (ea38253)
• push: implements Observable and PushStream independently (4c44fcd)
• push: implements Promise based Broker (Subscription) for PushStream (363ac24)
• push: improves performance (dd2262f)
• push: moves to a hook based error handling for Subscription; significant changes on types and PushStream behavior (6b3f3fa)
• push: removes static methods from PushStream; adds Create (6717e0f)
• PushStream: removes safe mode (54ff3f7)
• PushStream: Subscription is a lazy Promise, unsubscribes if rejected when listened to (fbf0da9)
• stream: adds Stream implementation (eac1dc6)
• streams: adds PushableStream (c2d85ed)
• streams: creates Push specific ObserverTalkback (5b3104a)
• utils: adds type guards (37204d9)
• adds closed getter to Core Talkback (8b67d18)
• adds Core Stream definitions (ce4a9da)
• adds Push Stream definitions (809fb96)
• adds PushStream implementation (4e4a4d3)
• adds Stream implementation (7b34134)
• aligns PushStream to ES Observable spec (4f71df7)
• defines and implements pull streams (6eff803)
• defines and implements pull streams as provider data returning only (889b444)
• forks w/ Observable reference implementation (66c3320)
• removes independent Observable reference implementation (3403b7c)
• Talkback doesn't allow manual early termination once another method has been called that deterministically will terminate (77fb909)
• utils: adds isIterable, isAsyncIterable, isObservable (af97988)