Comparing version 1.0.2 to 1.0.3
@@ -498,3 +498,14 @@ var _ = require('lodash'); | ||
var writable = this.connection && this.connection.writable && ((this.status === 'ready') || ((this.status === 'connected') && _.includes(Command.FLAGS.VALID_WHEN_LOADING, command.name))); | ||
var writable = (this.status === 'ready') || ((this.status === 'connected') && _.includes(Command.FLAGS.VALID_WHEN_LOADING, command.name)); | ||
if (!stream) { | ||
if (!this.connection) { | ||
writable = false; | ||
} else if (!this.connection.writable) { | ||
writable = false; | ||
} else if (this.connection._writableState && this.connection._writableState.ended) { | ||
// https://github.com/iojs/io.js/pull/1217 | ||
writable = false; | ||
} | ||
} | ||
if (writable) { | ||
@@ -501,0 +512,0 @@ debug('write command[%d] -> %s(%s)', this.condition.select, command.name, command.args); |
@@ -39,6 +39,3 @@ var Queue = require('fastqueue'); | ||
if (err) { | ||
// It's likely the connection has error or is closed, | ||
// in both case we just emit a silent error. | ||
self.flushQueue(new Error("Ready check failed: " + err.message)); | ||
self.silentEmit('error', err); | ||
return; | ||
@@ -45,0 +42,0 @@ } |
{ | ||
"name": "ioredis", | ||
"version": "1.0.2", | ||
"version": "1.0.3", | ||
"description": "A delightful, performance-focused Redis client for Node and io.js", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -466,3 +466,3 @@ # ioredis | ||
You can view the code at `benchmark.js`. | ||
You can find the code at `benchmark.js`. | ||
@@ -469,0 +469,0 @@ # Motivation |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
148480
45
3741