fixup

lib/connect.js

@@ -60,7 +60,7 @@ function createParser (client) {
       connect(client)
       setImmediate(() => client.emit('error', err))
     },
-    returnBuffers: client.buffers || client.messageBuffers,
+    returnBuffers: client._parserReturningBuffers,
     stringNumbers: client._options.stringNumbers || false
   })
 }

lib/reconnect.js

@@ -19,7 +19,7 @@ function retryConnection (client, error) {
     attempt: client.attempts,
     error,
     totalRetryTime: client.retryTotaltime,
-    timesConnected: client.timesConnected
+    timesConnected: client._timesConnected
   }
   client.emit('reconnecting', reconnectParams)
 
@@ -71,11 +71,11 @@ function reconnect (client, why, error) {
     return
   }
 
-  client.retryDelay = client.retryStrategy({
+  client.retryDelay = client._retryStrategy({
     attempt: client.attempts,
     error,
     totalRetryTime: client.retryTotaltime,
-    timesConnected: client.timesConnected
+    timesConnected: client._timesConnected
   })
   if (typeof client.retryDelay !== 'number') {
     var err

lib/replyHandler.js

@@ -42,7 +42,8 @@ function onResult (client, reply) {
   // the average performance of all other commands in case of no monitor mode
   if (client._monitoring === true) {
     var replyStr
-    if (client.buffers && Buffer.isBuffer(reply)) {
+    // TODO: This could be further improved performance wise
+    if (client._parserReturningBuffers && Buffer.isBuffer(reply)) {
       replyStr = reply.toString()
     } else {
       replyStr = reply

lib/utils.js

@@ -141,7 +141,7 @@ function warn (client, msg) {
  * @returns {string|number|null|Buffer|any[]|object}
  */
 function handleReply (client, reply, command) {
-  if (client._options.detectBuffers === true && command.bufferArgs === false || client.messageBuffers === true) {
+  if (client._options.detectBuffers === true && command.bufferArgs === false || client._messageBuffers === true) {
     reply = replyToStrings(reply)
   }