moved error handler

moscajs · Dec 23, 2017 · 033b805 · 033b805
1 parent 9a4eb04
commit 033b805
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/client.js b/lib/client.js
@@ -64,14 +64,14 @@ function Client (broker, conn) {
   }
   this._nextBatch = nextBatch
 
+  this.on('error', onError)
+
   nextBatch()
 
   conn.on('readable', nextBatch)
   conn.on('error', this.emit.bind(this, 'error'))
   this.parser.on('error', this.emit.bind(this, 'error'))
 
-  this.on('error', onError)
-
   this._eos = eos(this.conn, this.close.bind(this))
 
   function dedupe (packet) {