reconnect-core - npm Package Compare versions

Comparing version 0.2.1 to 0.2.2

index.js

@@ -19,3 +19,3 @@ var EventEmitter = require('events').EventEmitter
       emitter.on('connection', onConnect)
-    
+
     var backoffMethod = (backoff[opts.type] || backoff.fibonacci) (opts)
@@ -43,5 +43,10 @@
 
+      function onError (err) {
+        con.removeListener('error', onError)
+        emitter.emit('error', err)
+        onDisconnect(err)
+      }
+
       function onDisconnect (err) {
         emitter.connected = false
-        con.removeListener('error', onDisconnect)
         con.removeListener('close', onDisconnect)
@@ -63,3 +68,3 @@ con.removeListener('end'  , onDisconnect)
       con
-        .on('error', onDisconnect)
+        .on('error', onError)
         .on('close', onDisconnect)
@@ -66,0 +71,0 @@ .on('end'  , onDisconnect)

package.json

 {
   "name": "reconnect-core",
   "description": "Generic stream reconnection module.",
-  "version": "0.2.1",
+  "version": "0.2.2",
   "repository": {
@@ -46,2 +46,2 @@ "type": "git",
   }
-}
+}

README.md

@@ -41,2 +41,5 @@ # reconnect-core
 re.disconnect();
+
+// ...or prevent reconnecting
+re.reconnect = false;
 ```
@@ -43,0 +46,0 @@

test/attempts.js

@@ -8,3 +8,3 @@ var inject = require('..')
   process.nextTick(function () {
-    s.emit('error')
+    s.emit('error', new Error('oh noes!'))
   })
@@ -15,3 +15,3 @@ return s
 test('attempts', function (t) {
-  t.plan(14)
+  t.plan(21)
 
@@ -21,2 +21,6 @@ var fail = function () { t.fail() }
 
+  reconnector.on('error', function (err) {
+    t.equal(err.message, 'oh noes!', 'correct error message')
+  })
+
   var onReconnect = function (n, delay) {
@@ -23,0 +27,0 @@ t.equal(reconnector.connected, false)

No alert changes

Improved metrics

Total package byte prevSize

11637

increased by2.42%

Lines of code

259

increased by2.78%

Number of lines in readme file

87

increased by3.57%

No dependency changes