Struct BodyReader 

pub struct BodyReader { /* private fields */ }

Consumer end — stored in the reader registry. Uses tokio::sync::Mutex so we can .await the receiver without holding the registry’s std::sync::Mutex.

Per ADR-014 D4 this type implements http_body::Body directly so it can be wrapped into crate::Body without an intermediate StreamBody adapter. The two consumer paths are disjoint:

• Internal hyper path — the Body impl drives poll_frame. The BodyReader is moved into crate::Body::new and never registered in the FFI handle store.
• FFI path — JS calls next_chunk(handle) via HandleStore; the Body impl is never polled.

Implementations

impl BodyReader

pub async fn next_chunk(&self) -> Option<Bytes>

Receive the next chunk. Returns None when the writer is gone (EOF) or when the reader has been cancelled.

Trait Implementations

impl Body for BodyReader

ADR-014 D4: BodyReader is itself an http_body::Body so callers can wrap it in crate::Body::new without a StreamBody/unfold adapter.

type Data = Bytes

Values yielded by the Body.

type Error = Infallible

The error type this Body might generate.

fn poll_frame( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<Bytes>, Self::Error>>>

Attempt to pull out the next data buffer of this stream.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.