Struct NextStream 

pub struct NextStream<'a> { /* private fields */ }

The continuation an Interceptor calls to run the rest of a streaming chain.

NextStream holds the still-to-run interceptors and the terminal handler. run consumes it: an interceptor can call next.run(req, inbound) at most once. Not calling it short-circuits. Unlike Next, this is not Clone: the inbound stream is consumed as it is read and cannot be replayed, so a streaming chain runs once by construction.

Implementations

impl<'a> NextStream<'a>

pub async fn run( self, req: StreamRequest, inbound: PayloadStream, ) -> Result<StreamResponse, ConnectError>

Run the rest of the chain — the next interceptor if any, otherwise the terminal handler — and return its response.

Errors

Returns whatever error the next interceptor or handler produced.

Trait Implementations

impl Debug for NextStream<'_>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.