Fix daemon stream backpressure socket contract

Co-authored-by: Orca <help@stably.ai>
This commit is contained in:
brennanb2025
2026-07-02 01:43:35 -07:00
co-authored by Orca
parent f601a13828
commit d567368e8a
@@ -59,7 +59,7 @@ export class DaemonStreamBackpressureQueue {
for (let index = 0; index < lines.length; index += 1) {
const accepted = streamSocket.write(lines[index].line)
if (!accepted) {
if (accepted === false) {
this.deferUntilDrain(clientId, streamSocket, lines.slice(index + 1))
return
}