modify plugin name

2022-02-14 14:42:07 +08:00
parent 12a401be8e
commit a4bd152b59
1 changed files with 10 additions and 7 deletions
@@ -163,14 +163,17 @@ class Http extends Component
 							$open($request);
 						}
 					}
-					while (($data = $response->recv()) instanceof Frame) {
-						try {
-							if ($data->opcode == WEBSOCKET_OPCODE_PING || $data->opcode == WEBSOCKET_OPCODE_PONG) {
-								continue;
+
+					if ($response->isWritable()) {
+						while (($data = $response->recv()) instanceof Frame) {
+							try {
+								if ($data->opcode == WEBSOCKET_OPCODE_PING || $data->opcode == WEBSOCKET_OPCODE_PONG) {
+									continue;
+								}
+								call_user_func($message, $data);
+							} catch (\Throwable $throwable) {
+								$this->logger()->error($throwable->getMessage());
 							}
-							call_user_func($message, $data);
-						} catch (\Throwable $throwable) {
-							$this->logger()->error($throwable->getMessage());
 						}
 					}
 					call_user_func($close, $response->fd);