alkdev/alknet
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: alkdev:feat/http/gateway/invoke-streaming
Branches Tags
alkdev:main alkdev:develop alkdev:feat/http/server/subscribe-sse-streaming alkdev:feat/call/protocol/dispatch-streaming-branch alkdev:feat/http/gateway/invoke-streaming alkdev:feat/http/adapters/from-openapi-sse-streaming alkdev:feat/call/client/from-call-streaming-forwarding alkdev:feat/call/registry/invoke-streaming
...
compare: alkdev:b673b7f3172a859b6060e31e4c4d9724e0dce564
Branches Tags
alkdev:develop alkdev:feat/http/server/subscribe-sse-streaming alkdev:feat/call/protocol/dispatch-streaming-branch alkdev:feat/http/gateway/invoke-streaming alkdev:feat/http/adapters/from-openapi-sse-streaming alkdev:feat/call/client/from-call-streaming-forwarding alkdev:feat/call/registry/invoke-streaming alkdev:main

1 Commits
feat/http/ ... b673b7f317

Author SHA1 Message Date
glm-5.2
b673b7f317 docs(http): mark http/gateway/invoke-streaming completed — GatewayDispatch::invoke_streaming() 2026-07-02 09:55:15 +00:00
1 changed files with 2 additions and 2 deletions
Expand all files Collapse all files

4
tasks/http/gateway/invoke-streaming.md
View File

@@ -1,7 +1,7 @@
--- ---
id: http/gateway/invoke-streaming id: http/gateway/invoke-streaming
name: Implement GatewayDispatch::invoke_streaming() returning BoxStream<ResponseEnvelope> name: Implement GatewayDispatch::invoke_streaming() returning BoxStream<ResponseEnvelope>
status: pending status: completed
depends_on: [call/registry/invoke-streaming] depends_on: [call/registry/invoke-streaming]
scope: narrow scope: narrow
risk: medium risk: medium
@@ -127,4 +127,4 @@ don't duplicate the logic.
## Summary ## Summary
> To be filled on completion > Added GatewayDispatch::invoke_streaming() returning BoxStream<ResponseEnvelope>. Security axis provably identical to invoke() via shared build_root_context_inner(bounded: bool); extracted build_root_context_streaming for deadline: None (unbounded subscriptions). Calls OperationRegistry::invoke_streaming(). to_mcp untouched. Added 9 unit tests (all error paths + streaming dispatch + deadline: None verification). 243 tests pass.