Struct ResponseStream 

pub struct ResponseStream { /* private fields */ }

A streamed response body (issue #585).

Answering with one bridges the chunks to the wire without buffering them: on native (and in the test kit) the axum body is polled directly, so nothing runtime-specific is needed. A runtime that cannot bridge an axum body — runtime-cloudflare — instead calls ResponseStream::take to pull the stream out of the response extensions. Whoever takes first wins; the other side then sees an empty body.

Implementations

impl ResponseStream

pub fn new<S, O, E>(stream: S) -> Self

where S: Stream<Item = Result<O, E>> + Send + 'static, O: Into<Bytes> + 'static, E: Display + 'static,

Wraps stream as a response body. No ceiling: a streamed response is bounded by the handler that produced it, not by a request limit.

pub fn take(&self) -> Option<BoxStream<'static, Result<Bytes, StreamError>>>

Takes the underlying stream, for a runtime that bridges it to its own response type rather than polling the axum body — runtime-cloudflare builds a Worker response from it, because converting an axum body into a Worker Response hangs the isolate. None once the body has already been polled (or taken).

Panics

Panics if the slot’s lock is poisoned — only reachable if a prior poll panicked while holding it.

Trait Implementations

impl Clone for ResponseStream

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl IntoResponse for ResponseStream

fn into_response(self) -> Response

Create a response.