danog/ipc
1
0
Fork 0
mirror of https://github.com/danog/ipc.git synced 2024-11-30 04:29:09 +01:00
Code Issues Projects Releases Wiki Activity

Avoid hangs

Browse Source
This commit is contained in:
Daniil Gentili 2020-09-24 21:06:18 +02:00
parent 1313eb755a
commit 1ee91452f4
Signed by: danog
GPG Key ID: 8C1BE3B34B230CA7
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lib/Sync/ChannelledSocket.php
View File

@ -71,6 +71,9 @@ final class ChannelledSocket implements Channel
yield $this->channel->send(new ChannelCloseAck); yield $this->channel->send(new ChannelCloseAck);
$this->state = self::GOT_FIN_MASK; $this->state = self::GOT_FIN_MASK;
yield $this->disconnect(); yield $this->disconnect();
if ($this->closePromise) {
$this->closePromise->resolve($data);
}
return null; return null;
} elseif ($data instanceof ChannelCloseAck) { } elseif ($data instanceof ChannelCloseAck) {
$this->closePromise->resolve($data); $this->closePromise->resolve($data);