Skip to content

Commit 56d54c6

Browse files
committed
Replicate fix redis#1603 from jakepruitt
1 parent 4f85030 commit 56d54c6

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

index.js

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,9 @@ RedisClient.prototype.create_stream = function () {
220220
});
221221

222222
this.stream.on('error', function (err) {
223-
self.on_error(err);
223+
process.nextTick(function(){
224+
self.on_error(err);
225+
});
224226
});
225227

226228
this.stream.once('close', function (hadError) {

0 commit comments

Comments
 (0)