Struct StreamingInvocation 

pub struct StreamingInvocation { /* private fields */ }

Wrapper around an in-flight streaming invocation. Yields raw body chunks via Self::next_chunk until the RIE closes the response, at which point the final Ok(None) signals the caller to emit the terminal InvokeComplete frame.

Implementations

impl StreamingInvocation

pub async fn next_chunk(&mut self) -> Result<Option<Bytes>, RuntimeError>

Read the next chunk of the function’s response body. Returns Ok(None) once the RIE has finished streaming. Buffered handlers tend to deliver a single chunk; streaming handlers deliver one chunk per responseStream.write(...) call.