Commit7d8d6d7

committed

Fixed bug

1 parent5ed5f47 commit7d8d6d7Copy full SHA for 7d8d6d7

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -81,7 +81,8 @@ public function receive(Connection $connection)`
`81`	`81`
`82`	`82`	`if ($line =='*3') {`
`83`	`83`	`if (!empty($buffer)) {`
`84`		`-$this->resultChannel->push($buffer);`
	`84`	`+// 这里如果用 resultChannel 去 push 的话,会出现一种情况,就是这里 push 消息过后,没有地方去将消息 pop 出来,导致后续的消息都会被阻塞`
	`85`	`+$this->messageChannel->push($buffer);`
`85`	`86`	`$buffer =null;`
`86`	`87`	`}`
`87`	`88`	`$buffer[] =$line;`

Comments

(0)