Struct RequestBody 

pub struct RequestBody(/* private fields */);

A request body on the schema-routing pipeline.

A request entering through hyper keeps its Incoming body inside the Hyper state, without boxing. The routing service replaces it with the Buffered state after collecting for a body-first protocol. Other compatible HTTP bodies enter through RequestBody::new, which erases them into a boxed state.

RequestBody::prefixed replays bytes already read ahead of the remaining body. This allows middleware to inspect a prefix, then forward the full request without collecting the rest.

The states are private so buffering and transport-specific optimizations can evolve.

RequestBody is Send and Sync, so it can be handed to SdkBody::from_body_1_x when an operation input has a streaming member; SdkBody only accepts Sync bodies.

Implementations

impl RequestBody

pub fn new<T>(body: T) -> Self

where T: Body<Data = Bytes> + Send + Sync + 'static, T::Error: Into<BoxError>,

Wraps any compatible HTTP body without polling it.

A hyper incoming body and an already-wrapped RequestBody stay unerased; any other body type is erased into a boxed state.

pub fn prefixed(prefix: Bytes, trailers: Option<HeaderMap>, tail: Self) -> Self

Replays bytes already read from a request ahead of its remaining body.

Include all consumed data in prefix so downstream readers receive the full request. Construction does not poll or erase tail. An empty prefix with no captured trailers returns tail unchanged.

Pass None for trailers when only data has been read: unread trailers arrive from tail normally. If trailer frames were already read, pass them here to replay them after tail reaches end-of-stream.

pub fn empty() -> Self

Creates an empty request body.

pub fn from_bytes(bytes: Bytes) -> Self

Creates a request body containing buffered bytes.

Trait Implementations

impl Body for RequestBody

type Data = Bytes

Values yielded by the Body.

type Error = Error

The error type this Body might generate.

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

Attempt to pull out the next frame of this stream.

fn is_end_stream(&self) -> bool

A hint that may return true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

A hint that returns the bounds on the remaining length of the stream.

impl Debug for RequestBody

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

Formats the value using the given formatter.

impl Default for RequestBody

fn default() -> Self

Returns the “default value” for a type.

impl From<&'static [u8]> for RequestBody

fn from(bytes: &'static [u8]) -> Self

Converts to this type from the input type.

impl From<&'static str> for RequestBody

fn from(string: &'static str) -> Self

Converts to this type from the input type.

impl From<Bytes> for RequestBody

fn from(bytes: Bytes) -> Self

Converts to this type from the input type.

impl From<String> for RequestBody

fn from(string: String) -> Self

Converts to this type from the input type.

impl From<Vec<u8>> for RequestBody

fn from(bytes: Vec<u8>) -> Self

Converts to this type from the input type.