Enum Body 

pub enum Body {
    Empty,
    Bytes(Bytes),
    Text(String),
    Json(Value),
    Stream(StreamBody),
}

The body of a message, supporting common payload types.

Variants

Empty

No body content.

Bytes(Bytes)

Raw bytes payload.

Text(String)

UTF-8 string payload.

Json(Value)

JSON payload.

Stream(StreamBody)

Streaming payload.

Implementations

impl Body

pub fn is_empty(&self) -> bool

Returns true if the body is empty.

pub async fn into_bytes(self, max_size: usize) -> Result<Bytes, CamelError>

Convert the body into Bytes, consuming it if it is a stream. This is an async operation because it may need to read from an underlying stream. A max_size limit is enforced to prevent OOM errors.

pub async fn materialize(self) -> Result<Bytes, CamelError>

Materialize stream with sensible default limit (10MB).

Convenience method for common cases where you need the stream content but don’t want to specify a custom limit.

Example

let body = Body::Stream(stream);
let bytes = body.materialize().await?;

pub fn as_text(&self) -> Option<&str>

Try to get the body as a string, converting from bytes if needed.

pub fn try_into_text(self) -> Result<Body, CamelError>

Convert this body to Body::Text, consuming it. Returns Err(TypeConversionFailed) if the conversion is not possible. Body::Stream always fails — materialize with into_bytes() first.

pub fn try_into_json(self) -> Result<Body, CamelError>

Convert this body to Body::Json, consuming it. Returns Err(TypeConversionFailed) if the conversion is not possible. Body::Stream always fails — materialize with into_bytes() first.

pub fn try_into_bytes_body(self) -> Result<Body, CamelError>

Convert this body to Body::Bytes, consuming it. Returns Err(TypeConversionFailed) if the conversion is not possible. Body::Stream always fails — materialize with into_bytes() first.

Trait Implementations

impl Clone for Body

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Body

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

Formats the value using the given formatter.

impl Default for Body

fn default() -> Body

Returns the “default value” for a type.

impl From<&str> for Body

fn from(s: &str) -> Self

Converts to this type from the input type.

impl From<Bytes> for Body

fn from(b: Bytes) -> Self

Converts to this type from the input type.

impl From<String> for Body

fn from(s: String) -> Self

Converts to this type from the input type.

impl From<Value> for Body

fn from(v: Value) -> Self

Converts to this type from the input type.

impl From<Vec<u8>> for Body

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

Converts to this type from the input type.

impl PartialEq for Body

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.