@@ -162,9 +162,2 @@ | ||
| self._stopStallAbortTimeout(); | ||
| // We closed it explicitly - don't reconnect | ||
| if (self._abortedBy === 'twit-client') | ||
| return | ||
| // we got disconnected by twitter - reconnect according to their guidelines | ||
| self._abortedBy = 'twitter'; | ||
| if (self._scheduledReconnect) { | ||
@@ -194,3 +187,2 @@ // if we already have a reconnect scheduled, don't schedule another one. | ||
| StreamingAPIConnection.prototype.stop = function () { | ||
| this._abortedBy = 'twit-client'; | ||
| // clear connection variables and timeout handles | ||
@@ -197,0 +189,0 @@ this._resetConnection(); |
+1
-1
| { | ||
| "name": "twit", | ||
| "description": "Twitter API client for node (REST & Streaming)", | ||
| "version": "2.2.2", | ||
| "version": "2.2.3", | ||
| "author": "Tolga Tezel", | ||
@@ -6,0 +6,0 @@ "keywords": [ |
@@ -26,3 +26,2 @@ var assert = require('assert'); | ||
| assert.equal(typeof disconnect, 'object'); | ||
| assert.equal(stream.abortedBy, 'twit-client'); | ||
| done(); | ||
@@ -29,0 +28,0 @@ }); |
@@ -29,7 +29,3 @@ var assert = require('assert') | ||
| stream.once('tweet', function (tweet) { | ||
| assert.equal(null, stream._abortedBy) | ||
| stream.stop() | ||
| assert.equal('twit-client', stream._abortedBy) | ||
| assert.ok(tweet) | ||
@@ -60,3 +56,2 @@ assert.equal('string', typeof tweet.text) | ||
| exports.checkStreamStopState = function (stream) { | ||
| assert.strictEqual('twit-client', stream._abortedBy) | ||
| assert.strictEqual(stream._connectInterval, 0) | ||
@@ -133,3 +128,2 @@ assert.strictEqual(stream._usedFirstReconnect, false) | ||
| setTimeout(function () { | ||
| assert.equal(null, stream._abortedBy) | ||
| stream.stop() | ||
@@ -136,0 +130,0 @@ |
634671
-0.08%2737
-0.4%