diff --git a/lib/Redis.php b/lib/Redis.php
index <HASH>..<HASH> 100644
--- a/lib/Redis.php
+++ b/lib/Redis.php
@@ -140,7 +140,13 @@ class Redis {
 			}
 
 			$this->readWatcher = $this->reactor->onReadable($this->socket, function () {
-				$this->onRead();
+				$read = fread($this->socket, 8192);
+		
+				if ($read != "") {
+					$this->parser->append($read);
+				} elseif (!is_resource($this->socket) || @feof($this->socket)) {
+					$this->close(true);
+				}
 			});
 
 			$this->writeWatcher = $this->reactor->onWritable($this->socket, function (Reactor $reactor, $watcherId) {
@@ -153,16 +159,6 @@ class Redis {
 		return $this->connectPromisor->promise();
 	}
 
-	private function onRead () {
-		$read = fread($this->socket, 8192);
-
-		if ($read != "") {
-			$this->parser->append($read);
-		} elseif (!is_resource($this->socket) || @feof($this->socket)) {
-			$this->close(true);
-		}
-	}
-
 	private function onResponse ($result) {
 		if ($this->mode === self::MODE_DEFAULT) {
 			$promisor = array_shift($this->promisors);
inlined onRead code

saves a method call per read