Struct RequestStream 

pub struct RequestStream { /* private fields */ }

Server-side stream of inbound request chunk bodies for one client-streaming (or duplex) call. Yields one Bytes per DISPATCH_RPC_REQUEST / DISPATCH_RPC_REQUEST_CHUNK frame (including empty bodies — the semantics of “empty bytes” are the application’s concern, not the substrate’s). Closes on FLAG_RPC_REQUEST_END or on CANCEL.

Stream item ordering convention: the first item this stream yields corresponds to the initial REQUEST body; every subsequent item corresponds to a REQUEST_CHUNK body, in the order the chunks were received from the wire. The substrate does not tag items with their frame kind — the SDK veneer (Phase E) is responsible for the Init / Data classification via its Chunk<T> enum.

Auto-grant behavior: when the caller opted into request-direction flow control via HEADER_NRPC_REQUEST_WINDOW_INITIAL, every successful poll_next() fires one credit back to the caller via the captured grant_emitter. This keeps the in-flight window at the caller’s initial value as the handler drains the stream. When the caller did NOT opt in (no header), the grant_emitter is None and the auto-grant path is a no-op (caller is on the unbounded-credit fast path).

Bidi streaming plan (Phase B).

Trait Implementations

impl Stream for RequestStream

type Item = Bytes

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.