From 62bebe5122193e3a98d4925cbb97bcd272403589 Mon Sep 17 00:00:00 2001 From: "glm-5.2" Date: Thu, 2 Jul 2026 09:48:39 +0000 Subject: [PATCH] =?UTF-8?q?docs(http):=20mark=20http/adapters/from-openapi?= =?UTF-8?q?-sse-streaming=20completed=20=E2=80=94=20SSE=20streaming=20forw?= =?UTF-8?q?arding?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tasks/http/adapters/from-openapi-sse-streaming.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tasks/http/adapters/from-openapi-sse-streaming.md b/tasks/http/adapters/from-openapi-sse-streaming.md index a30b2ce..ae9cd5d 100644 --- a/tasks/http/adapters/from-openapi-sse-streaming.md +++ b/tasks/http/adapters/from-openapi-sse-streaming.md @@ -1,7 +1,7 @@ --- id: http/adapters/from-openapi-sse-streaming name: Implement from_openapi Subscription forwarding as StreamingHandler (SSE response → BoxStream) -status: pending +status: completed depends_on: [call/registry/streaming-handler-handlerkind] scope: narrow risk: medium @@ -240,4 +240,4 @@ HandlerRegistration::new(spec, handler, OperationProvenance::FromOpenAPI, None, ## Summary -> To be filled on completion \ No newline at end of file +> Branched build_registration on op_type: Subscription → make_streaming_handler + forward_stream() (HandlerKind::Stream), Query/Mutation → existing make_handler + forward() (HandlerKind::Once). forward_stream() sends Accept: text/event-stream, streams SSE chunks via stream::unfold over response.bytes_stream(), reusing parse_sse_frames; each data: frame → one ResponseEnvelope::ok(), HTTP error → single ResponseEnvelope::error(), SSE end → ResponseStream ends. Removed stream_subscription() collect-all placeholder. Added 4 tests + updated integration test. 234 tests pass. \ No newline at end of file