shared-store - npm Package Compare versions

Comparing version 1.0.8 to 1.0.9

CHANGELOG.md

@@ -0,1 +1,5 @@
+1.0.9
+-----
+* fix getaddrinfo ENOTFOUND by connecting only when subscribed - @chkhoo #17
+
 1.0.8
@@ -2,0 +6,0 @@ -----

lib/cache.js

@@ -164,5 +164,7 @@ // Generated by CoffeeScript 1.9.0
   fromCache = tryCache(tmpDir);
-  data.connect();
   cachedData = fromCache.takeUntil(data).merge(data).distinctUntilChanged(property('data'), isEqual).flatMapLatest(partial(writeCache, tmpDir)).publish();
-  cachedData.connect();
+  cachedData.connectAll = function() {
+    data.connect();
+    return cachedData.connect();
+  };
   return cachedData;
@@ -175,3 +177,3 @@ };
   data = rawData.publish();
-  data.connect();
+  data.connectAll = data.connect;
   return data;
@@ -178,0 +180,0 @@ };

lib/dir-content.js

@@ -133,3 +133,3 @@ // Generated by CoffeeScript 1.9.0
   };
-  initial = fromPromiseFunction(statDir).flatMap(Observable.fromArray);
+  initial = fromPromiseFunction(statDir).flatMap(Observable.from);
   if (watch) {
@@ -136,0 +136,0 @@ return initial.concat(dirChanges(dir, {

lib/interval.js

@@ -35,8 +35,6 @@ // Generated by CoffeeScript 1.9.0
 'use strict';
-var Observable, Promise, onInterval;
+var Observable, onInterval;
 
 Observable = require('rx').Observable;
 
-Promise = require('bluebird');
-
 onInterval = function(interval, load) {
@@ -43,0 +41,0 @@ if (interval > 0) {

lib/shared-store.js

@@ -87,3 +87,4 @@ // Generated by CoffeeScript 1.9.0
         _this.stream = cachedLoader(meta, loader, temp, active);
-        return _this.subscription = _this.stream.subscribe(_this._handleUpdate, _this._handleError);
+        _this.subscription = _this.stream.subscribe(_this._handleUpdate, _this._handleError);
+        return _this.stream.connectAll();
       };
@@ -90,0 +91,0 @@ })(this);

package.json

 {
   "name": "shared-store",
-  "version": "1.0.8",
+  "version": "1.0.9",
   "description": "Keeping config data in sync",
@@ -5,0 +5,0 @@ "main": "lib/shared-store.js",

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

96815

increased by0.2%

Lines of code

1106

increased by0.18%

No dependency changes