Open aogg opened 1 day ago
比如下面代码应该改为受保护的,而不是私有的
private function dispatch(int $fd, string $nsp, string $event, ...$payloads): void
{
$socket = $this->makeSocket($fd, $nsp);
if (empty($socket)) {
return;
}
$ack = null;
// Check if ack is required
$last = array_pop($payloads);
if ($last instanceof Closure) {
$ack = $last;
} else {
array_push($payloads, $last);
}
$handlers = $this->getEventHandlers($nsp, $event);
foreach ($handlers as $handler) {
$result = $handler($socket, ...$payloads);
$ack && $ack([$result]);
}
}
如题