handle handshake error

sidorares · sidorares · commit e808a8304641 · 2016-08-13T17:44:18.000+10:00
diff --git a/lib/connection.js b/lib/connection.js
@@ -108,6 +108,9 @@ function Connection (opts)
       connection.threadId = handshakeCommand.handshake.connectionId;
       connection.emit('connect', handshakeCommand.handshake);
     });
+    handshakeCommand.on('error', function(err) {
+      connection._notifyError(err);
+    });
     this.addCommand(handshakeCommand);
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -108,6 +108,9 @@ function Connection (opts)`
`108`	`108`	`connection.threadId = handshakeCommand.handshake.connectionId;`
`109`	`109`	`connection.emit('connect', handshakeCommand.handshake);`
`110`	`110`	`});`
	`111`	`+ handshakeCommand.on('error', function(err) {`
	`112`	`+ connection._notifyError(err);`
	`113`	`+ });`
`111`	`114`	`this.addCommand(handshakeCommand);`
`112`	`115`	`}`
`113`	`116`	`}`