isahc

Struct AsyncBody

Source
pub struct AsyncBody(/* private fields */);
Expand description

Contains the body of an asynchronous HTTP request or response.

This type is used to encapsulate the underlying stream or region of memory where the contents of the body are stored. An AsyncBody can be created from many types of sources using the Into trait or one of its constructor functions.

For asynchronous requests, you must use an asynchronous body, because the entire request lifecycle is also asynchronous. You can create a body from anything that implements AsyncRead, which AsyncBody itself also implements.

For synchronous requests, use Body instead.

Implementations§

Source§

impl AsyncBody

Source

pub const fn empty() -> Self

Create a new empty body.

An empty body represents the absence of a body, which is semantically different than the presence of a body of zero length.

Source

pub fn from_bytes_static<B>(bytes: B) -> Self
where B: AsRef<[u8]> + 'static,

Create a new body from a potentially static byte buffer.

The body will have a known length equal to the number of bytes given.

This will try to prevent a copy if the type passed in can be re-used, otherwise the buffer will be copied first. This method guarantees to not require a copy for the following types:

  • &'static [u8]
  • &'static str
§Examples
use isahc::Body;

// Create a body from a static string.
let body = Body::from_bytes_static("hello world");
Source

pub fn from_reader<R>(read: R) -> Self
where R: AsyncRead + Send + Sync + 'static,

Create a streaming body that reads from the given reader.

The body will have an unknown length. When used as a request body, chunked transfer encoding might be used to send the request.

Source

pub fn from_reader_sized<R>(read: R, length: u64) -> Self
where R: AsyncRead + Send + Sync + 'static,

Create a streaming body with a known length.

If the size of the body is known in advance, such as with a file, then this function can be used to create a body that can determine its Content-Length while still reading the bytes asynchronously.

Giving a value for length that doesn’t actually match how much data the reader will produce may result in errors when sending the body in a request.

Source

pub fn is_empty(&self) -> bool

Report if this body is empty.

This is not necessarily the same as checking for self.len() == Some(0). Since HTTP message bodies are optional, there is a semantic difference between the absence of a body and the presence of a zero-length body. This method will only return true for the former.

Source

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

Get the size of the body, if known.

The value reported by this method is used to set the Content-Length for outgoing requests.

When coming from a response, this method will report the value of the Content-Length response header if present. If this method returns None then there’s a good chance that the server used something like chunked transfer encoding to send the response body.

Since the length may be determined totally separately from the actual bytes, even if a value is returned it should not be relied on as always being accurate, and should be treated as a “hint”.

Source

pub fn reset(&mut self) -> bool

If this body is repeatable, reset the body stream back to the start of the content. Returns false if the body cannot be reset.

Trait Implementations§

Source§

impl AsyncRead for AsyncBody

Source§

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

Attempt to read from the AsyncRead into buf. Read more
Source§

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. Read more
Source§

impl Debug for AsyncBody

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for AsyncBody

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl From<&[u8]> for AsyncBody

Source§

fn from(body: &[u8]) -> Self

Converts to this type from the input type.
Source§

impl From<&str> for AsyncBody

Source§

fn from(body: &str) -> Self

Converts to this type from the input type.
Source§

impl From<()> for AsyncBody

Source§

fn from(_: ()) -> Self

Converts to this type from the input type.
Source§

impl<T: Into<Self>> From<Option<T>> for AsyncBody

Source§

fn from(body: Option<T>) -> Self

Converts to this type from the input type.
Source§

impl From<String> for AsyncBody

Source§

fn from(body: String) -> Self

Converts to this type from the input type.
Source§

impl From<Vec<u8>> for AsyncBody

Source§

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

Converts to this type from the input type.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<R> AsyncReadExt for R
where R: AsyncRead + ?Sized,

Source§

fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadFuture<'a, Self>
where Self: Unpin,

Reads some bytes from the byte stream. Read more
Source§

fn read_vectored<'a>( &'a mut self, bufs: &'a mut [IoSliceMut<'a>], ) -> ReadVectoredFuture<'a, Self>
where Self: Unpin,

Like read(), except it reads into a slice of buffers. Read more
Source§

fn read_to_end<'a>( &'a mut self, buf: &'a mut Vec<u8>, ) -> ReadToEndFuture<'a, Self>
where Self: Unpin,

Reads the entire contents and appends them to a Vec. Read more
Source§

fn read_to_string<'a>( &'a mut self, buf: &'a mut String, ) -> ReadToStringFuture<'a, Self>
where Self: Unpin,

Reads the entire contents and appends them to a String. Read more
Source§

fn read_exact<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadExactFuture<'a, Self>
where Self: Unpin,

Reads the exact number of bytes required to fill buf. Read more
Source§

fn take(self, limit: u64) -> Take<Self>
where Self: Sized,

Creates an adapter which will read at most limit bytes from it. Read more
Source§

fn bytes(self) -> Bytes<Self>
where Self: Sized,

Converts this AsyncRead into a Stream of bytes. Read more
Source§

fn chain<R>(self, next: R) -> Chain<Self, R>
where R: AsyncRead, Self: Sized,

Creates an adapter which will chain this stream with another. Read more
Source§

fn boxed_reader<'a>(self) -> Pin<Box<dyn AsyncRead + Send + 'a>>
where Self: Sized + Send + 'a,

Boxes the reader and changes its type to dyn AsyncRead + Send + 'a. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> MaybeSendSync for T