Потоки

go-like использует потоковую модель самой Web-платформы. Запрос — обычный Request, ответ — обычный Response, а body может быть ReadableStream<Uint8Array>. Отдельного класса Stream, DSL для кадров и выдуманного двунаправленного канала поверх одноразового body здесь нет.

Публичный HTTP streaming принадлежит @go-like/web и нативному Handler выбранного фреймворка. Unary-вызов несёт одно JSON-тело. Server stream с stream: true — это SSE на POST /<service>/<endpoint> (accept: text/event-stream), а не двусторонний многокадровый протокол. Handler — async *. Клиент сначала await получает ServerStream, затем for await. Закрытие: close() или await using. streamKeepAlive по умолчанию 15000 мс; 0 оставляет только первый комментарий. maxSendMessageBytes по умолчанию 4 МиБ и считает целое UTF-8 SSE-событие; превышение — resource_exhausted / HTTP 429. Memory опережает не больше чем на одно сообщение; HTTP prefetch ограничен и не совпадает 1:1 с for await. Не делайте в генераторе эффект, который предполагает, что событие уже доставлено. При deadline клиент пишет Go-Like-Timeout-Ms. Context запроса живёт до конца тела ответа. Client-streaming и bidi остаются в @go-like/transport-grpc-buf/native.

Web body читается только один раз. Middleware не должен потреблять его, если не собирается явно предоставить замену. Отмена проходит через первый Context и signal запроса. Transport проверяет, что каждый chunk является Uint8Array; неверное значение превращается в ошибку протокола, а не в загадочно пустые данные.

Для внешнего HTTP используйте @go-like/web вместе с Hono, Elysia, H3 или собственным handler. SSE, потоковые ответы и runtime-specific WebSocket upgrade остаются в исходном фреймворке; go-like сохраняет нативные объекты и ошибки.

contextHandler освобождает свой Context после возврата Response из Handler, а не после завершения body. Долгоживущий producer должен следить за request.signal или владеть отдельной областью отмены.

@go-like/protoc-gen-like генерирует Protobuf RPC с первым аргументом Context на основе Protobuf-ES. @go-like/transport-grpc-buf предоставляет unary и server-streaming Connect/gRPC-Web через Fetch; /native добавляет стандартный gRPC со всеми четырьмя видами вызовов, включая client-streaming и bidi. Этот путь независим от внутреннего пути Fetch/SSE.

Управляемый gRPC в Node 26.12.1 и Bun 1.4.4 прошёл регрессионный тест drain с медленным потребителем. Ранее наблюдались сохранение таймера deadline в Connect 2.1.2 после отмены приостановленного потока ответа и отсутствие доставки отмены Fetch в Bun 1.4.2 серверу, молчащему после первого chunk. См. доказательства и ограничения; этот прогон не подтверждает исправление двух ранее выявленных ограничений.