as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-10-09 17:31:50 +08:00
parent 50c377d795
commit 8bef56226b
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Socket.php
+5 -5
View File
@@ -399,11 +399,11 @@ class Socket
$bytesToWrite = strlen($this->writeBuffer);
$bytesWritten = $this->stream->send($this->writeBuffer);
if ($bytesToWrite === $bytesWritten) {
\Amp\disable($this->writeWatcher);
} elseif ($bytesWritten >= 0) {
\Amp\enable($this->writeWatcher);
}
// if ($bytesToWrite === $bytesWritten) {
// \Amp\disable($this->writeWatcher);
// } elseif ($bytesWritten >= 0) {
// \Amp\enable($this->writeWatcher);
// }
$this->writeBuffer = substr($this->writeBuffer, $bytesWritten);
}