@reactive-js/ix - npm Package Compare versions

Comparing version 0.0.13 to 0.0.14

dist/cjs/index.js

@@ -36,3 +36,3 @@ "use strict";
     const dispatcher = rx_1.createSubject();
-    return exports.createAsyncIteratorResource(dispatcher.next.bind(dispatcher), dispatcher, dispatcher);
+    return exports.createAsyncIteratorResource(dispatcher.onNext.bind(dispatcher), dispatcher, dispatcher);
 };
@@ -42,3 +42,3 @@ exports.createReducerStore = (initialState, reducer, scheduler, equals) => {
     const observable = pipe_1.pipe(dispatcher, observable_1.scan(reducer, () => initialState), observable_1.startWith(initialState), observable_1.distinctUntilChanged(equals), observable_1.share(scheduler, 1));
-    const store = exports.createAsyncIteratorResource(dispatcher.next.bind(dispatcher), observable, dispatcher);
+    const store = exports.createAsyncIteratorResource(dispatcher.onNext.bind(dispatcher), observable, dispatcher);
     return store.add(pipe_1.pipe(store, rx_1.subscribe(scheduler)));
@@ -50,7 +50,7 @@ };
     const dispatcher = rx_1.createSubject();
-    const onPersistentStoreChangedStream = pipe_1.pipe(persistentStore, observable_1.onNext(v => dispatcher.next(_ => v)), observable_1.ignoreElements());
+    const onPersistentStoreChangedStream = pipe_1.pipe(persistentStore, observable_1.onNext(v => dispatcher.onNext(_ => v)), observable_1.ignoreElements());
     const stateObs = pipe_1.pipe(dispatcher, observable_1.scan((acc, next) => next(acc), () => initialState), observable_1.distinctUntilChanged(equals), observable_1.onNext(next => persistentStore.dispatch(next)));
     const observable = pipe_1.pipe(observable_1.merge(onPersistentStoreChangedStream, stateObs), observable_1.share(scheduler, 1));
-    return exports.createAsyncIteratorResource(dispatcher.next.bind(dispatcher), observable, dispatcher);
+    return exports.createAsyncIteratorResource(dispatcher.onNext.bind(dispatcher), observable, dispatcher);
 };
 //# sourceMappingURL=index.js.map

dist/esm5/index.js

@@ -34,3 +34,3 @@ import { subscribe, createSubject, } from "@reactive-js/rx";
     const dispatcher = createSubject();
-    return createAsyncIteratorResource(dispatcher.next.bind(dispatcher), dispatcher, dispatcher);
+    return createAsyncIteratorResource(dispatcher.onNext.bind(dispatcher), dispatcher, dispatcher);
 };
@@ -40,3 +40,3 @@ export const createReducerStore = (initialState, reducer, scheduler, equals) => {
     const observable = pipe(dispatcher, scan(reducer, () => initialState), startWith(initialState), distinctUntilChanged(equals), share(scheduler, 1));
-    const store = createAsyncIteratorResource(dispatcher.next.bind(dispatcher), observable, dispatcher);
+    const store = createAsyncIteratorResource(dispatcher.onNext.bind(dispatcher), observable, dispatcher);
     return store.add(pipe(store, subscribe(scheduler)));
@@ -48,7 +48,7 @@ };
     const dispatcher = createSubject();
-    const onPersistentStoreChangedStream = pipe(persistentStore, onNext(v => dispatcher.next(_ => v)), ignoreElements());
+    const onPersistentStoreChangedStream = pipe(persistentStore, onNext(v => dispatcher.onNext(_ => v)), ignoreElements());
     const stateObs = pipe(dispatcher, scan((acc, next) => next(acc), () => initialState), distinctUntilChanged(equals), onNext(next => persistentStore.dispatch(next)));
     const observable = pipe(merge(onPersistentStoreChangedStream, stateObs), share(scheduler, 1));
-    return createAsyncIteratorResource(dispatcher.next.bind(dispatcher), observable, dispatcher);
+    return createAsyncIteratorResource(dispatcher.onNext.bind(dispatcher), observable, dispatcher);
 };
 //# sourceMappingURL=index.js.map

package.json

 {
   "name": "@reactive-js/ix",
-  "version": "0.0.13",
+  "version": "0.0.14",
   "main": "dist/cjs/index.js",
@@ -41,7 +41,7 @@ "module": "dist/esm5/index.js",
   "dependencies": {
-    "@reactive-js/disposable": "^0.0.13",
-    "@reactive-js/observable": "^0.0.13",
-    "@reactive-js/pipe": "^0.0.13",
-    "@reactive-js/rx": "^0.0.13",
-    "@reactive-js/scheduler": "^0.0.13"
+    "@reactive-js/disposable": "^0.0.14",
+    "@reactive-js/observable": "^0.0.14",
+    "@reactive-js/pipe": "^0.0.14",
+    "@reactive-js/rx": "^0.0.14",
+    "@reactive-js/scheduler": "^0.0.14"
   },
@@ -58,3 +58,3 @@ "scripts": {
   },
-  "gitHead": "86211c5e64b3702b5e3b00dc31d40a79f35bd02f"
+  "gitHead": "8a86dc5efc38fdfe6683765bf2ff3eb14f3820de"
 }

src/index.ts

@@ -115,3 +115,3 @@ import {
   return createAsyncIteratorResource(
-    dispatcher.next.bind(dispatcher),
+    dispatcher.onNext.bind(dispatcher),
     dispatcher,
@@ -137,3 +137,3 @@ dispatcher,
   const store = createAsyncIteratorResource(
-    dispatcher.next.bind(dispatcher),
+    dispatcher.onNext.bind(dispatcher),
     observable,
@@ -165,3 +165,3 @@ dispatcher,
     persistentStore,
-    onNext(v => dispatcher.next(_ => v)),
+    onNext(v => dispatcher.onNext(_ => v)),
     ignoreElements(),
@@ -186,3 +186,3 @@ );
   return createAsyncIteratorResource(
-    dispatcher.next.bind(dispatcher),
+    dispatcher.onNext.bind(dispatcher),
     observable,
@@ -189,0 +189,0 @@ dispatcher,

No alert changes

Improved metrics

Total package byte prevSize

516969

Dependency changes

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

• + Added@reactive-js/observable@0.0.14(transitive)

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

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

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

• + Added@reactive-js/schedulers@0.0.14(transitive)

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

• - Removed@reactive-js/observable@0.0.13(transitive)

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

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

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

• - Removed@reactive-js/schedulers@0.0.13(transitive)

• Updated@reactive-js/disposable@^0.0.14

• Updated@reactive-js/observable@^0.0.14

• Updated@reactive-js/pipe@^0.0.14

• Updated@reactive-js/rx@^0.0.14

• Updated@reactive-js/scheduler@^0.0.14