@reactive-js/ix - npm Package Compare versions

Comparing version 0.0.23 to 0.0.24

dist/cjs/index.d.ts

 export { AsyncIterableLike, AsyncIteratorLike, AsyncIteratorResourceLike, StateUpdaterLike, } from "./internal/interfaces";
 export { createAsyncIteratorResource } from "./internal/createAsyncIterator";
+export { disposedAsyncIteratorResource } from "./internal/disposedIterator";
 export { empty } from "./internal/empty";
@@ -9,4 +10,4 @@ export { fromArray } from "./internal/fromArray";
 export { lift, liftReq } from "./internal/lift";
-export { reduceAsync } from "./internal/reduceAsync";
-export { createActionReducerAsyncIterable, createStateAsyncIterable, } from "./internal/reducerAsyncIterable";
-export { createPersistentStateAsyncIterable } from "./internal/persistentStateAsyncIterable";
+export { scanAsync } from "./internal/scanAsync";
+export { createActionReducerAsyncIterable, createStateUpdaterAsyncIterable, } from "./internal/reducerAsyncIterable";
+export { toStateUpdaterAsyncIterable } from "./internal/delegatingStateUpdaterAsyncIterable";

dist/cjs/index.js

@@ -5,2 +5,4 @@ "use strict";
 exports.createAsyncIteratorResource = createAsyncIterator_1.createAsyncIteratorResource;
+var disposedIterator_1 = require("./internal/disposedIterator");
+exports.disposedAsyncIteratorResource = disposedIterator_1.disposedAsyncIteratorResource;
 var empty_1 = require("./internal/empty");
@@ -19,9 +21,9 @@ exports.empty = empty_1.empty;
 exports.liftReq = lift_1.liftReq;
-var reduceAsync_1 = require("./internal/reduceAsync");
-exports.reduceAsync = reduceAsync_1.reduceAsync;
+var scanAsync_1 = require("./internal/scanAsync");
+exports.scanAsync = scanAsync_1.scanAsync;
 var reducerAsyncIterable_1 = require("./internal/reducerAsyncIterable");
 exports.createActionReducerAsyncIterable = reducerAsyncIterable_1.createActionReducerAsyncIterable;
-exports.createStateAsyncIterable = reducerAsyncIterable_1.createStateAsyncIterable;
-var persistentStateAsyncIterable_1 = require("./internal/persistentStateAsyncIterable");
-exports.createPersistentStateAsyncIterable = persistentStateAsyncIterable_1.createPersistentStateAsyncIterable;
+exports.createStateUpdaterAsyncIterable = reducerAsyncIterable_1.createStateUpdaterAsyncIterable;
+var delegatingStateUpdaterAsyncIterable_1 = require("./internal/delegatingStateUpdaterAsyncIterable");
+exports.toStateUpdaterAsyncIterable = delegatingStateUpdaterAsyncIterable_1.toStateUpdaterAsyncIterable;
 //# sourceMappingURL=index.js.map

dist/cjs/internal/reducerAsyncIterable.d.ts

 import { StateUpdaterLike, AsyncIterableLike } from "./interfaces";
 export declare const createActionReducerAsyncIterable: <TAction, T>(reducer: (state: T, action: TAction) => T, initialStateFactory: () => T, equals?: ((a: T, b: T) => boolean) | undefined) => AsyncIterableLike<TAction, T>;
-export declare const createStateAsyncIterable: <T>(initialState: () => T, equals?: ((a: T, b: T) => boolean) | undefined) => AsyncIterableLike<StateUpdaterLike<T>, T>;
+export declare const createStateUpdaterAsyncIterable: <T>(initialState: () => T, equals?: ((a: T, b: T) => boolean) | undefined) => AsyncIterableLike<StateUpdaterLike<T>, T>;

dist/cjs/internal/reducerAsyncIterable.js

@@ -22,3 +22,3 @@ "use strict";
 const stateStoreReducer = (state, action) => action(state);
-exports.createStateAsyncIterable = (initialState, equals) => exports.createActionReducerAsyncIterable(stateStoreReducer, initialState, equals);
+exports.createStateUpdaterAsyncIterable = (initialState, equals) => exports.createActionReducerAsyncIterable(stateStoreReducer, initialState, equals);
 //# sourceMappingURL=reducerAsyncIterable.js.map

dist/esm5/index.d.ts

 export { AsyncIterableLike, AsyncIteratorLike, AsyncIteratorResourceLike, StateUpdaterLike, } from "./internal/interfaces";
 export { createAsyncIteratorResource } from "./internal/createAsyncIterator";
+export { disposedAsyncIteratorResource } from "./internal/disposedIterator";
 export { empty } from "./internal/empty";
@@ -9,4 +10,4 @@ export { fromArray } from "./internal/fromArray";
 export { lift, liftReq } from "./internal/lift";
-export { reduceAsync } from "./internal/reduceAsync";
-export { createActionReducerAsyncIterable, createStateAsyncIterable, } from "./internal/reducerAsyncIterable";
-export { createPersistentStateAsyncIterable } from "./internal/persistentStateAsyncIterable";
+export { scanAsync } from "./internal/scanAsync";
+export { createActionReducerAsyncIterable, createStateUpdaterAsyncIterable, } from "./internal/reducerAsyncIterable";
+export { toStateUpdaterAsyncIterable } from "./internal/delegatingStateUpdaterAsyncIterable";

dist/esm5/index.js

 export { createAsyncIteratorResource } from "./internal/createAsyncIterator";
+export { disposedAsyncIteratorResource } from "./internal/disposedIterator";
 export { empty } from "./internal/empty";
@@ -8,5 +9,5 @@ export { fromArray } from "./internal/fromArray";
 export { lift, liftReq } from "./internal/lift";
-export { reduceAsync } from "./internal/reduceAsync";
-export { createActionReducerAsyncIterable, createStateAsyncIterable, } from "./internal/reducerAsyncIterable";
-export { createPersistentStateAsyncIterable } from "./internal/persistentStateAsyncIterable";
+export { scanAsync } from "./internal/scanAsync";
+export { createActionReducerAsyncIterable, createStateUpdaterAsyncIterable, } from "./internal/reducerAsyncIterable";
+export { toStateUpdaterAsyncIterable } from "./internal/delegatingStateUpdaterAsyncIterable";
 //# sourceMappingURL=index.js.map

dist/esm5/internal/reducerAsyncIterable.d.ts

 import { StateUpdaterLike, AsyncIterableLike } from "./interfaces";
 export declare const createActionReducerAsyncIterable: <TAction, T>(reducer: (state: T, action: TAction) => T, initialStateFactory: () => T, equals?: ((a: T, b: T) => boolean) | undefined) => AsyncIterableLike<TAction, T>;
-export declare const createStateAsyncIterable: <T>(initialState: () => T, equals?: ((a: T, b: T) => boolean) | undefined) => AsyncIterableLike<StateUpdaterLike<T>, T>;
+export declare const createStateUpdaterAsyncIterable: <T>(initialState: () => T, equals?: ((a: T, b: T) => boolean) | undefined) => AsyncIterableLike<StateUpdaterLike<T>, T>;

dist/esm5/internal/reducerAsyncIterable.js

@@ -20,3 +20,3 @@ import { pipe } from "@reactive-js/pipe";
 const stateStoreReducer = (state, action) => action(state);
-export const createStateAsyncIterable = (initialState, equals) => createActionReducerAsyncIterable(stateStoreReducer, initialState, equals);
+export const createStateUpdaterAsyncIterable = (initialState, equals) => createActionReducerAsyncIterable(stateStoreReducer, initialState, equals);
 //# sourceMappingURL=reducerAsyncIterable.js.map

dist/types/index.d.ts

 export { AsyncIterableLike, AsyncIteratorLike, AsyncIteratorResourceLike, StateUpdaterLike, } from "./internal/interfaces";
 export { createAsyncIteratorResource } from "./internal/createAsyncIterator";
+export { disposedAsyncIteratorResource } from "./internal/disposedIterator";
 export { empty } from "./internal/empty";
@@ -9,5 +10,5 @@ export { fromArray } from "./internal/fromArray";
 export { lift, liftReq } from "./internal/lift";
-export { reduceAsync } from "./internal/reduceAsync";
-export { createActionReducerAsyncIterable, createStateAsyncIterable, } from "./internal/reducerAsyncIterable";
-export { createPersistentStateAsyncIterable } from "./internal/persistentStateAsyncIterable";
+export { scanAsync } from "./internal/scanAsync";
+export { createActionReducerAsyncIterable, createStateUpdaterAsyncIterable, } from "./internal/reducerAsyncIterable";
+export { toStateUpdaterAsyncIterable } from "./internal/delegatingStateUpdaterAsyncIterable";
 //# sourceMappingURL=index.d.ts.map

dist/types/internal/reducerAsyncIterable.d.ts

 import { StateUpdaterLike, AsyncIterableLike } from "./interfaces";
 export declare const createActionReducerAsyncIterable: <TAction, T>(reducer: (state: T, action: TAction) => T, initialStateFactory: () => T, equals?: ((a: T, b: T) => boolean) | undefined) => AsyncIterableLike<TAction, T>;
-export declare const createStateAsyncIterable: <T>(initialState: () => T, equals?: ((a: T, b: T) => boolean) | undefined) => AsyncIterableLike<StateUpdaterLike<T>, T>;
+export declare const createStateUpdaterAsyncIterable: <T>(initialState: () => T, equals?: ((a: T, b: T) => boolean) | undefined) => AsyncIterableLike<StateUpdaterLike<T>, T>;
 //# sourceMappingURL=reducerAsyncIterable.d.ts.map

docs/README.md

@@ -15,2 +15,6 @@ [@reactive-js/ix](README.md)
 
+### Variables
+
+* [disposedAsyncIteratorResource](README.md#const-disposedasynciteratorresource)
+
 ### Functions
@@ -20,4 +24,3 @@
 * [createAsyncIteratorResource](README.md#const-createasynciteratorresource)
-* [createPersistentStateAsyncIterable](README.md#const-createpersistentstateasynciterable)
-* [createStateAsyncIterable](README.md#const-createstateasynciterable)
+* [createStateUpdaterAsyncIterable](README.md#const-createstateupdaterasynciterable)
 * [empty](README.md#const-empty)
@@ -30,4 +33,11 @@ * [fromArray](README.md#const-fromarray)
 * [liftReq](README.md#liftreq)
-* [reduceAsync](README.md#const-reduceasync)
+* [scanAsync](README.md#const-scanasync)
+* [toStateUpdaterAsyncIterable](README.md#const-tostateupdaterasynciterable)
 
+## Variables
+
+### `Const` disposedAsyncIteratorResource
+
+• **disposedAsyncIteratorResource**: *[AsyncIteratorResourceLike](interfaces/asynciteratorresourcelike.md)‹unknown, any›* =  _disposed
+
 ## Functions
@@ -90,5 +100,5 @@
 
-### `Const` createPersistentStateAsyncIterable
+### `Const` createStateUpdaterAsyncIterable
 
-▸ **createPersistentStateAsyncIterable**<**T**>(`persistentStoreIterable`: [AsyncIterableLike](interfaces/asynciterablelike.md)‹T, T›, `initialState`: function, `equals?`: undefined | function): *[AsyncIterableLike](interfaces/asynciterablelike.md)‹[StateUpdaterLike](interfaces/stateupdaterlike.md)‹T›, T›*
+▸ **createStateUpdaterAsyncIterable**<**T**>(`initialState`: function, `equals?`: undefined | function): *[AsyncIterableLike](interfaces/asynciterablelike.md)‹[StateUpdaterLike](interfaces/stateupdaterlike.md)‹T›, T›*
 
@@ -101,4 +111,2 @@ **Type parameters:**
 
-▪ **persistentStoreIterable**: *[AsyncIterableLike](interfaces/asynciterablelike.md)‹T, T›*
-
 ▪ **initialState**: *function*
@@ -114,22 +122,2 @@
 
-### `Const` createStateAsyncIterable
-
-▸ **createStateAsyncIterable**<**T**>(`initialState`: function, `equals?`: undefined | function): *[AsyncIterableLike](interfaces/asynciterablelike.md)‹[StateUpdaterLike](interfaces/stateupdaterlike.md)‹T›, T›*
-
-**Type parameters:**
-
-▪ **T**
-
-**Parameters:**
-
-▪ **initialState**: *function*
-
-▸ (): *T*
-
-▪`Optional`  **equals**: *undefined | function*
-
-**Returns:** *[AsyncIterableLike](interfaces/asynciterablelike.md)‹[StateUpdaterLike](interfaces/stateupdaterlike.md)‹T›, T›*
-
-___
-
 ### `Const` empty
@@ -689,5 +677,5 @@
 
-### `Const` reduceAsync
+### `Const` scanAsync
 
-▸ **reduceAsync**<**TReq**, **TSrc**, **TAcc**>(`reducer`: function, `initial`: function, `scheduler`: SchedulerLike): *OperatorLike‹[AsyncIterableLike](interfaces/asynciterablelike.md)‹TReq, TSrc›, ObservableLike‹TAcc››*
+▸ **scanAsync**<**TReq**, **TSrc**, **TAcc**>(`reducer`: function, `initial`: function, `scheduler`: SchedulerLike): *OperatorLike‹[AsyncIterableLike](interfaces/asynciterablelike.md)‹TReq, TSrc›, ObservableLike‹TAcc››*
 
@@ -722,1 +710,21 @@ **Type parameters:**
 **Returns:** *OperatorLike‹[AsyncIterableLike](interfaces/asynciterablelike.md)‹TReq, TSrc›, ObservableLike‹TAcc››*
+
+___
+
+### `Const` toStateUpdaterAsyncIterable
+
+▸ **toStateUpdaterAsyncIterable**<**T**>(`initialState`: function, `equals?`: undefined | function): *[AsyncIterableOperatorLike](interfaces/asynciterableoperatorlike.md)‹T, T, [StateUpdaterLike](interfaces/stateupdaterlike.md)‹T›, T›*
+
+**Type parameters:**
+
+▪ **T**
+
+**Parameters:**
+
+▪ **initialState**: *function*
+
+▸ (): *T*
+
+▪`Optional`  **equals**: *undefined | function*
+
+**Returns:** *[AsyncIterableOperatorLike](interfaces/asynciterableoperatorlike.md)‹T, T, [StateUpdaterLike](interfaces/stateupdaterlike.md)‹T›, T›*

package.json

 {
   "name": "@reactive-js/ix",
-  "version": "0.0.23",
+  "version": "0.0.24",
   "main": "dist/cjs/index.js",
@@ -41,9 +41,9 @@ "module": "dist/esm5/index.js",
   "dependencies": {
-    "@reactive-js/disposable": "^0.0.23",
-    "@reactive-js/pipe": "^0.0.23",
-    "@reactive-js/rx": "^0.0.23",
-    "@reactive-js/scheduler": "^0.0.23"
+    "@reactive-js/disposable": "^0.0.24",
+    "@reactive-js/pipe": "^0.0.24",
+    "@reactive-js/rx": "^0.0.24",
+    "@reactive-js/scheduler": "^0.0.24"
   },
   "devDependencies": {
-    "@reactive-js/schedulers": "^0.0.23",
+    "@reactive-js/schedulers": "^0.0.24",
     "@types/jest": "^24.0.23",
@@ -74,3 +74,3 @@ "jest": "^24.9.0",
   },
-  "gitHead": "413ea5c12bc7b59dcc73cab0e33ff3c9acd941f2"
+  "gitHead": "19ba0c0276afd9ca23aae5497c04c1f63d2d72a4"
 }

src/index.ts

@@ -9,3 +9,3 @@ export {
 export { createAsyncIteratorResource } from "./internal/createAsyncIterator";
-
+export { disposedAsyncIteratorResource } from "./internal/disposedIterator";
 export { empty } from "./internal/empty";
@@ -17,7 +17,7 @@ export { fromArray } from "./internal/fromArray";
 export { lift, liftReq } from "./internal/lift";
-export { reduceAsync } from "./internal/reduceAsync";
+export { scanAsync } from "./internal/scanAsync";
 export {
   createActionReducerAsyncIterable,
-  createStateAsyncIterable,
+  createStateUpdaterAsyncIterable,
 } from "./internal/reducerAsyncIterable";
-export { createPersistentStateAsyncIterable } from "./internal/persistentStateAsyncIterable";
+export { toStateUpdaterAsyncIterable } from "./internal/delegatingStateUpdaterAsyncIterable";

src/internal/reducerAsyncIterable.ts

@@ -43,3 +43,3 @@ import { pipe } from "@reactive-js/pipe";
   action(state);
-export const createStateAsyncIterable = <T>(
+export const createStateUpdaterAsyncIterable = <T>(
   initialState: () => T,
@@ -46,0 +46,0 @@ equals?: (a: T, b: T) => boolean,

test/index.spec.ts

 import { createVirtualTimeSchedulerResource } from "@reactive-js/schedulers";
-import { fromArray, fromIterable, generate, reduceAsync } from "../src/index";
+import { fromArray, fromIterable, generate, scanAsync } from "../src/index";
 import { pipe } from "@reactive-js/pipe";
@@ -10,2 +10,3 @@ import {
   ofValue,
+  takeLast,
 } from "@reactive-js/rx";
@@ -80,3 +81,3 @@
 
-test("reduceAsync", () => {
+test("scanAsync", () => {
   const scheduler = createVirtualTimeSchedulerResource(1);
@@ -88,3 +89,3 @@ const iter = fromIterable([1, 2, 3, 4, 5, 6]);
     iter,
-    reduceAsync(
+    scanAsync(
       (acc, next) => ofValue({ result: acc + next }),
@@ -94,2 +95,3 @@ () => ({ request: undefined, result: 0 }),
     ),
+    takeLast(),
     onNext(x => {
@@ -96,0 +98,0 @@ result = x;

No alert changes

Improved metrics

Total package byte prevSize

694835

increased by0.8%

Number of package files

135

increased by7.14%

Lines of code

1646

increased by1.48%

Dependency changes

• + Added@reactive-js/disposable@0.0.24(transitive)

• + Added@reactive-js/pipe@0.0.24(transitive)

• + Added@reactive-js/rx@0.0.24(transitive)

• + Added@reactive-js/scheduler@0.0.24(transitive)

• - Removed@reactive-js/disposable@0.0.23(transitive)

• - Removed@reactive-js/pipe@0.0.23(transitive)

• - Removed@reactive-js/rx@0.0.23(transitive)

• - Removed@reactive-js/scheduler@0.0.23(transitive)

• Updated@reactive-js/disposable@^0.0.24

• Updated@reactive-js/pipe@^0.0.24

• Updated@reactive-js/rx@^0.0.24

• Updated@reactive-js/scheduler@^0.0.24