Struct roa_core::Body

pub struct Body { /* fields omitted */ }

The Body of Request and Response.

Example

use roa_core::Body;
use async_std::fs::File;
use futures::io::AsyncReadExt;

#[async_std::main]
async fn main() -> std::io::Result<()> {
    let mut body = Body::default();
    let mut data = String::new();
    body.write_buf(b"He".as_ref())
        .write_buf(b"llo, ".as_ref())
        .write(File::open("../assets/author.txt").await?)
        .write_buf(b".".as_ref())
        .read_to_string(&mut data)
        .await?;
    assert_eq!("Hello, Hexilee.", data);
    Ok(())
}

Methods

impl Body

pub fn write_buf(
    &mut self,
    buf_reader: impl BufRead + Sync + Send + Unpin + 'static
) -> &mut Self

Write reader implementing BufRead.

pub fn write(
    &mut self,
    reader: impl Read + Sync + Send + Unpin + 'static
) -> &mut Self

Write reader implementing Read.

pub fn write_bytes(&mut self, bytes: impl Into<Vec<u8>>) -> &mut Self

Write Vec<u8>.

pub fn write_str(&mut self, data: impl ToString) -> &mut Self

Write String.

pub fn stream(self) -> BodyStream<Self>

Into a stream.

pub fn on_finish(
    &mut self,
    callback: impl 'static + Sync + Send + Unpin + Fn(&Self)
) -> &mut Self

Callback when dropping body.

Example

use roa_core::Body;
use async_std::fs::File;
use futures::io::AsyncReadExt;
#[async_std::test]
async fn body_on_finish() -> std::io::Result<()> {
    let mut body = Body::default();
    let mut data = String::new();
    body.write_buf(b"He".as_ref())
        .write_buf(b"llo, ".as_ref())
        .write_buf(b"World".as_ref())
        .on_finish(|body| assert_eq!(12, body.consumed()))
        .read_to_string(&mut data)
        .await?;
    assert_eq!("Hello, World", data);
    Ok(())
}

pub fn consumed(&self) -> usize

Get the numbers of consumed bytes.

Trait Implementations

impl AsyncBufRead for Body

fn poll_fill_buf(
    self: Pin<&mut Self>,
    cx: &mut Context
) -> Poll<Result<&[u8], Error>>

Attempt to return the contents of the internal buffer, filling it with more data from the inner reader if it is empty.

fn consume(self: Pin<&mut Self>, amt: usize)

Tells this buffer that amt bytes have been consumed from the buffer, so they should no longer be returned in calls to [poll_read].

impl AsyncRead for Body

fn poll_read(
    self: Pin<&mut Self>,
    cx: &mut Context,
    buf: &mut [u8]
) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored(
    self: Pin<&mut Self>,
    cx: &mut Context,
    bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl Default for Body

fn default() -> Self

Returns the "default value" for a type.

impl Drop for Body

fn drop(&mut self)

Executes the destructor for this type.