instanceof AsyncTcpConnection) {
$proxy->upstream->resumeRecv();
}
};
}
/**
* 处理上游原始响应数据=> $throwable->getCode(),
]);
$this->finishClientStream($clientConnection);
}
}
/**
* 发送上游响应体>send(new Chunk($buffer), true) === false) {
Log::channel('media_downloader_response')->warning('发送数据块失败->send(new Chunk($data), true) === false) {
Log::channel('media_downloader_response')->warning('发送chunk数据失败', [
'url_hash' => md5($state['url']),
]);
$upstreamConnection->close();
$this