[Flight] Encode ReadableStream and AsyncIterables - #28847

Merged

sebmarkbage merged 11 commits into

sebmarkbage:flightreadablestream

Apr 16, 2024

Commits on Apr 16, 2024

Add feature flag
sebmarkbage
committed
60f5c61
Serialize ReadableStream and AsyncIterable
sebmarkbage
committed
7dd8e6f
Propagate a cancel/abort signal to the serialized streams
sebmarkbage
committed
bed74ee
Implement Consuming AsyncIterables
sebmarkbage
committed
65f0172
Add a wrapper fragment if an AsyncIterable needs to be keyed
sebmarkbage
committed
105fa03
Port sync resolution in thenables which are preinstrumented like Flight
sebmarkbage
committed
e12febf
Forward debug info to async iterables
sebmarkbage
committed
f77a171
If a model is blocked on a direct dependency we need to wait to enqueue it
sebmarkbage
committed
8e33e92
Try to synchronously emit a task if possible using the stream id
sebmarkbage
committed
cecd166
Emit root strings or typed arrays without outlining
sebmarkbage
committed
e8d5dea
Fix gates
sebmarkbage
committed
0fddb4e