Streaming callbacks with multiplexed transport - #3931

Open

T4rk1n wants to merge 17 commits into

feat/shared_storagefrom

Commits on Sep 1, 2026

Add streaming callbacks (@callback generator functions)
T4rk1n
committed
ce7530c
Multiplex HTTP streams over shared storage
T4rk1n
committed
e33a79b
Streaming: verify connections, stop on shutdown, reset stale cursor
T4rk1n
committed
6ff0621
trigger PR recheck
T4rk1n
committed
5d17895
Fix FastAPI startup crash: replace removed add_event_handler
T4rk1n
committed
55c2891
Fix Ctrl+C hang with active streaming downlink on Flask
T4rk1n
committed
7e491ce
Poll at 0.5s in keepalive generator so shutdown is noticed quickly
T4rk1n
committed
bcbbbca
Move local imports to top level, add shutdown tests
T4rk1n
committed
f01fbbf
Check shutdown flag in async keepalive generator too
T4rk1n
committed
0366d91
Move stream shutdown signal handler to _stream_hub
T4rk1n
committed
d0ee3d7
Handle KeyboardInterrupt in FastAPI subprocess runner
T4rk1n
committed
698adf1

Commits on Sep 2, 2026