0.0.8 (2021-09-18)
- push: fix Multicast.of (f72b4ca)
- push: catches recursively catches errors & resubscribes to the original observable by default (d0b7cb1)
- push: catches ooperator: subscriptions to observables due to errors being catched are performed asynchronously
0.0.7 (2021-07-01)
- deps: update type-core dependency (5a0ce49)
- push: adds value option to Multicast (5bbfc3b)
0.0.6 (2021-06-11)
- push: fix filter operator types (41e7bf9)
0.0.5 (2020-12-22)
- push: fixes take operator leak (ce10ecc)
0.0.4 (2020-12-20)
- push: renames changes operator as compare (e8c0671)
- push: adds start operator (51de47f)
- push: The changes operator is now exported as compare
0.0.3 (2020-12-18)
- push: fixes mergeMap operator types (53a9fd4)
- push: adds start operator (d34bc11)
0.0.2 (2020-12-15)
- push: adds first consume operator (94a0b30)
0.0.1 (2020-12-12)
- adds missing dependencies (ecb6a8c)
- aligns PushStream.from and reference Observable.from with Observable spec (a83dbc6)
- definitions: fixes push definitions (78b69e5)
- definitions: fixes push definitions (625d4a6)
- deps: fixes dangling and pending dependencies (d6e7dd1)
- deps: updates dependencies (e4a187f)
- deps: updates dependencies (887d284)
- deps: updates type-core version (8d8f67c)
- 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)
- helpers: fixes FailureManager (82eebf3)
- push: fixes Broker promise methods when passed via Hearback.start (05da612)
- push: fixes circular dependencies (ef071be)
- push: fixes circular dependencies (b735828)
- push: fixes from creation function (cfcb0eb)
- push: fixes PushableStream (7ca929b)
- 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)
- 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)
- creation: adds combine (06ffbc5)
- defines and implements pull streams (6eff803)
- defines and implements pull streams as provider data returning only (889b444)
- definitions: adds definitions for iterables (fead788)
- exports compliant Observable w/ extensions; removes PushStream; renames PushableStream to Subject; renames PullableStream to Pullable (76d59e5)
- forks w/ Observable reference implementation (66c3320)
- 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)
- 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 operate and forward utils (ac17f47)
- 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 switchMap operator (7dcd637)
- push: adds take operator (cedf7d4)
- push: adds tap operator (3854710)
- push: adds terminate to PushStream Hearback (8993f22)
- push: adds timestamp operator (9b1186b)
- push: adds trail operator (308d695)
- push: adds transform and intercept utils, redesigns operate, replaces forward with Forwarder (7028e81)
- push: deprecates Subject.start in favor or Subject.of (d18c20b)
- 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)
- removes independent Observable reference implementation (3403b7c)
- stream: adds Stream implementation (eac1dc6)
- streams: adds PushableStream (c2d85ed)
- streams: creates Push specific ObserverTalkback (5b3104a)
- Talkback doesn't allow manual early termination once another method has been called that deterministically will terminate (77fb909)
- utils: adds isIterable, isAsyncIterable, isObservable (af97988)
- utils: adds type guards (37204d9)