Module streaming 

Structs

ObservedRecvStream

Wrapper that records receive boundaries for a streaming response.

RpcStreamingObserver

Lightweight observer for streaming RPC adapters.

RpcStreamingSnapshot

Point-in-time streaming RPC observation snapshot.

Functions

record_stream_send

Runs one streaming send operation with send observation.

run_observed_stream

Runs a streaming future with optional timeout and final observation.