abraxas - npm Package Compare versions

Comparing version 2.0.2 to 2.1.0

client-connection.js

		@@ -35,3 +35,2 @@ "use strict";
		init.begin();
		this.socket.write({kind:'request',type:packet.types['OPTION_REQ'],args:{option:'exceptions'}});
		this.packets.acceptSerialWithError('OPTION_RES', function (err,data) {
		@@ -44,6 +43,6 @@ init.end();
		});
		this.socket.write({kind:'request',type:packet.types['OPTION_REQ'],args:{option:'exceptions'}});

		if (options.streaming) {
		init.begin();
		this.socket.write({kind:'request',type:packet.types['OPTION_REQ'],args:{option:'streaming'}});
		var trace = AbraxasError.trace(ClientConnection);
		@@ -65,2 +64,3 @@ this.packets.acceptSerialWithError('OPTION_RES', function (err,data) {
		});
		this.socket.write({kind:'request',type:packet.types['OPTION_REQ'],args:{option:'streaming'}});
		}
		@@ -269,4 +269,4 @@ }
		ClientConnection.prototype.adminSingleResult = function (command, handler) {
		this.socket.write({kind:'admin',type:packet.adminTypes['line'],args:{line:command}});
		this.packets.acceptSerialAdminWithError('ADMIN:ok', handler);
		this.socket.write({kind:'admin',type:packet.adminTypes['line'],args:{line:command}});
		}
		@@ -273,0 +273,0 @@

client-reconnect.js

		@@ -69,11 +69,1 @@ "use strict";
		}

		for (var name in ClientConnection.prototype) { (function(name) {
		if (name.substr(0,1)=='_') return;
		var func = Promise.prototype[name];
		if (!(func instanceof Function)) return;
		ClientReconnect.prototype[name] = function () {
		if (!this.socket) throw Error("Can't proxy "+name+" when connection doesn't have valid socket");
		return func.apply(this.socket,arguments);
		}
		})(name) }

package.json

		@@ -12,14 +12,15 @@ {
		"author": "Rebecca Turner <me@re-becca.org> (http://re-becca.org)",
		"version": "2.0.2",
		"version": "2.1.0",
		"dependencies": {
		"bluebird": "^2.1.3",
		"backoff": "^2.4.0",
		"bluebird": "^2.3.2",
		"concat-stream": "^1.4.6",
		"duplex-combination": "^1.1.1",
		"duplex-combination": "^1.2.0",
		"emptyfunction": "0.0.0",
		"gearman-packet": "^1.0.1",
		"gearman-packet": "^1.0.2",
		"isa-stream": "^1.0.1",
		"readable-stream": "^1.0.0",
		"shallow-copy": "^0.0.1",
		"readable-stream": "^1.1.13",
		"shallow-copy": "0.0.1",
		"standard-error": "^1.1.0",
		"through2": "^0.6.1",
		"through2": "^1.1.1",
		"util-extend": "^1.0.1"
		@@ -41,2 +42,3 @@ },
		"devDependencies": {
		"stream-array": "^0.1.3",
		"tape": "^2.13.4"
		@@ -43,0 +45,0 @@ },

task-client.js

		@@ -80,4 +80,4 @@ "use strict";
		if (this.responseTimeout) clearTimeout(this.responseTimeout);
		this.completed = true;
		if (result == null) {
		this.completed = true;
		this.reader.end();
		@@ -87,4 +87,10 @@ }
		result.pipe(this.reader);
		var self = this;
		result.on('error',function (err){ this.reader.emit(err) });
		result.on('end',function(){
		self.completed = true;
		});
		}
		else {
		this.completed = true;
		this.reader._writableState.objectMode = true;
		@@ -91,0 +97,0 @@ this.reader._readableState.objectMode = true;

New alerts