reactive-di - npm Package Compare versions

Comparing version 3.1.2 to 3.1.3

dist/source/Updater.js

@@ -104,6 +104,9 @@ 'use strict';
         var source = this._source;
-        source.merge(v);
         var observer = this._updater;
-        if (observer && observer.next) {
-            observer.next(v);
+        if (v) {
+            source.merge(v);
+            if (observer && observer.next) {
+                observer.next(v);
+            }
+            this._v = v;
         }
@@ -113,3 +116,2 @@ notifier.opId = oldId;
         notifier.flush();
-        this._v = v;
     };
@@ -116,0 +118,0 @@

package.json

 {
   "name": "reactive-di",
-  "version": "3.1.2",
+  "version": "3.1.3",
   "description": "Reactive dependency injection",
@@ -5,0 +5,0 @@ "publishConfig": {

src/source/interfaces.js

@@ -31,3 +31,3 @@ // @flow
 type IUpdaterBase<V> = {
-    next?: (v: V) => void;
+    next?: (v: ?V) => void;
     complete?: (v: ?V) => void;
@@ -38,6 +38,6 @@ error?: (e: Error) => void;
 export type IUpdater<V> = IUpdaterBase<V> & {
-    promise: () => Promise<V>;
+    promise: () => Promise<any>;
 } | IUpdaterBase<V> & {
     promise: void;
-    observable: () => Observable<V, Error>;
+    observable: () => Observable<any | void, Error>;
 }
@@ -44,0 +44,0 @@

src/source/Updater.js

@@ -91,3 +91,3 @@ // @flow
             this._subscription = updater.observable()
-                .subscribe((this: Observer<V, Error>))
+                .subscribe((this: Observer<?V, Error>))
         }
@@ -104,3 +104,3 @@ }
 
-    next(v: V): void {
+    next(v: ?V): void {
         if (this._isCanceled) {
@@ -115,6 +115,9 @@ return
         const source = this._source
-        source.merge(v)
         const observer = this._updater
-        if (observer && observer.next) {
-            observer.next(v)
+        if (v) {
+            source.merge(v)
+            if (observer && observer.next) {
+                observer.next(v)
+            }
+            this._v = v
         }
@@ -124,3 +127,2 @@ notifier.opId = oldId
         notifier.flush()
-        this._v = v
     }
@@ -127,0 +129,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

365171

increased by0.05%

Lines of code

5056

increased by0.08%

No dependency changes