Enum servlin::RequestBody

pub enum RequestBody {
    PendingKnown(u64),
    PendingUnknown,
    StaticBytes(&'static [u8]),
    StaticStr(&'static str),
    Vec(Vec<u8>),
    File(PathBuf, u64),
    TempFile(TempFile, u64),
}

Variants

PendingKnown(u64)

PendingUnknown

StaticBytes(&'static [u8])

StaticStr(&'static str)

Vec(Vec<u8>)

File(PathBuf, u64)

TempFile(TempFile, u64)

Implementations

impl RequestBody

pub fn empty() -> Self

pub fn is_pending(&self) -> bool

Examples found in repository

examples/http-put.rs (line 54)

fn put(state: Arc<State>, req: Request) -> Result<Response, Error> {
    if req.body.is_pending() {
        return Ok(Response::get_body_and_reprocess(1024 * 1024));
    }
    let body_len = req.body.reader()?.bytes().count();
    state.upload_count.fetch_add(1, Ordering::AcqRel);
    Ok(Response::text(
        200,
        format!(
            "Upload received, body_len={}, upload_count={}\n",
            body_len,
            state.upload_count.load(Ordering::Acquire)
        ),
    ))
}

pub fn is_empty(&self) -> Option<bool>

pub fn len(&self) -> Option<u64>

Returns the body length, if it is known.

pub fn reader(&self) -> Result<BodyReader<'_>, Error>

Errors

Returns an error when the body is cached in a file and we fail to open the file.

Examples found in repository

examples/http-put.rs (line 57)

fn put(state: Arc<State>, req: Request) -> Result<Response, Error> {
    if req.body.is_pending() {
        return Ok(Response::get_body_and_reprocess(1024 * 1024));
    }
    let body_len = req.body.reader()?.bytes().count();
    state.upload_count.fetch_add(1, Ordering::AcqRel);
    Ok(Response::text(
        200,
        format!(
            "Upload received, body_len={}, upload_count={}\n",
            body_len,
            state.upload_count.load(Ordering::Acquire)
        ),
    ))
}

pub async fn async_reader(&self) -> Result<BodyAsyncReader<'_>, Error>

Errors

Returns an error when the body is cached in a file and we fail to open the file.

Trait Implementations

impl Clone for RequestBody

fn clone(&self) -> RequestBody

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RequestBody

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

Formats the value using the given formatter.

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

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

Converts to this type from the input type.

impl From<&'static str> for RequestBody

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

Converts to this type from the input type.

impl<const LEN: usize> From<[u8; LEN]> for RequestBody

fn from(b: [u8; LEN]) -> Self

Converts to this type from the input type.

impl From<String> for RequestBody

fn from(s: String) -> Self

Converts to this type from the input type.

impl From<Vec<u8>> for RequestBody

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

Converts to this type from the input type.

impl PartialEq for RequestBody

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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl TryFrom<RequestBody> for String

type Error = Error

The type returned in the event of a conversion error.

fn try_from(body: RequestBody) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<RequestBody> for Vec<u8>

type Error = Error

The type returned in the event of a conversion error.

fn try_from(body: RequestBody) -> Result<Self, Self::Error>

Performs the conversion.

impl Eq for RequestBody

impl StructuralEq for RequestBody

impl StructuralPartialEq for RequestBody