Fix read buffer processing

DaveRandom · DaveRandom · commit 915ff72a3138 · 2013-02-24T23:06:54.000Z
diff --git a/src/WebSocketServer/Socket/Client.php b/src/WebSocketServer/Socket/Client.php
@@ -357,7 +357,8 @@ public function processRead()
             if (!$this->handshake->isComplete()) {
                 $this->shakeHands();
             } else {
-                $this->messageDecoder->processData($this->buffer);
+                // keep processing until there are no complete frames left in the buffer
+                while ($this->messageDecoder->processData($this->buffer));
             }
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -357,7 +357,8 @@ public function processRead()`
`357`	`357`	`if (!$this->handshake->isComplete()) {`
`358`	`358`	`$this->shakeHands();`
`359`	`359`	`} else {`
`360`		`- $this->messageDecoder->processData($this->buffer);`
	`360`	`+ // keep processing until there are no complete frames left in the buffer`
	`361`	`+ while ($this->messageDecoder->processData($this->buffer));`
`361`	`362`	`}`
`362`	`363`	`}`
`363`	`364`	`}`