Struct qiniu_http::AsyncRequestBody

pub struct AsyncRequestBody<'a>(_);

Available on crate feature async only.

异步 HTTP 请求体

Implementations

impl<'a> AsyncRequestBody<'a>

pub fn from_referenced_reader<T: AsyncRead + AsyncReset + Unpin + Debug + Send + Sync + 'a>(
    reader: &'a mut T,
    size: u64
) -> Self

通过异步输入流的可变引用创建异步 HTTP 请求体

Examples found in repository

src/request.rs (line 945)

            fn from(body: &'a mut AsyncRequestBody<'_>) -> Self {
                Self::from_referenced_reader(body, body.size())
            }

pub fn from_referenced_bytes(bytes: &'a [u8]) -> Self

通过二进制数据的引用创建异步 HTTP 请求体

Examples found in repository

src/request.rs (line 952)

            fn from(body: &'a [u8]) -> Self {
                Self::from_referenced_bytes(body)
            }
        }

        impl<'a> From<&'a str> for AsyncRequestBody<'a> {
            #[inline]
            fn from(body: &'a str) -> Self {
                Self::from_referenced_bytes(body.as_bytes())
            }

pub fn from_reader(
    reader: impl AsyncRead + AsyncReset + Unpin + Debug + Send + Sync + 'static,
    size: u64
) -> Self

通过异步输入流创建异步 HTTP 请求体

pub fn from_bytes(bytes: Vec<u8>) -> Self

通过二进制数据创建异步 HTTP 请求体

Examples found in repository

src/request.rs (line 906)

            fn default() -> Self {
                Self::from_bytes(Default::default())
            }
        }

        impl AsyncRead for AsyncRequestBody<'_> {
            fn poll_read(mut self: Pin<&mut Self>, cx: &mut Context, buf: &mut [u8]) -> Poll<IoResult<usize>> {
                match &mut self.as_mut().0 {
                    AsyncRequestBodyInner::ReaderRef { reader, .. } => {
                        pin!(reader);
                        reader.poll_read(cx, buf)
                    }
                    AsyncRequestBodyInner::BytesRef(bytes) => {
                        pin!(bytes);
                        bytes.poll_read(cx, buf)
                    }
                    AsyncRequestBodyInner::Owned(owned) => {
                        pin!(owned);
                        owned.poll_read(cx, buf)
                    }
                }
            }
        }

        impl AsyncReset for AsyncRequestBody<'_> {
            #[inline]
            fn reset(&mut self) -> BoxFuture<IoResult<()>> {
                Box::pin(async move {
                    match &mut self.0 {
                        AsyncRequestBodyInner::ReaderRef { reader, .. } => reader.reset().await,
                        AsyncRequestBodyInner::BytesRef(bytes) => bytes.reset().await,
                        AsyncRequestBodyInner::Owned(owned) => owned.reset().await,
                    }
                })
            }
        }

        impl<'a> From<&'a mut AsyncRequestBody<'_>> for AsyncRequestBody<'a> {
            #[inline]
            fn from(body: &'a mut AsyncRequestBody<'_>) -> Self {
                Self::from_referenced_reader(body, body.size())
            }
        }

        impl<'a> From<&'a [u8]> for AsyncRequestBody<'a> {
            #[inline]
            fn from(body: &'a [u8]) -> Self {
                Self::from_referenced_bytes(body)
            }
        }

        impl<'a> From<&'a str> for AsyncRequestBody<'a> {
            #[inline]
            fn from(body: &'a str) -> Self {
                Self::from_referenced_bytes(body.as_bytes())
            }
        }

        impl From<Vec<u8>> for AsyncRequestBody<'_> {
            #[inline]
            fn from(body: Vec<u8>) -> Self {
                Self::from_bytes(body)
            }
        }

        impl From<String> for AsyncRequestBody<'_> {
            #[inline]
            fn from(body: String) -> Self {
                Self::from_bytes(body.into_bytes())
            }

pub fn size(&self) -> u64

获取请求体大小

单位为字节

Examples found in repository

src/request.rs (line 945)

            fn from(body: &'a mut AsyncRequestBody<'_>) -> Self {
                Self::from_referenced_reader(body, body.size())
            }

Trait Implementations

impl AsyncRead for AsyncRequestBody<'_>

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

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 AsyncReset for AsyncRequestBody<'_>

fn reset(&mut self) -> Pin<Box<dyn Future<Output = IoResult<()>> + Send + '_>>

Available on crate feature async only.

异步重置输入流

impl<'a> Debug for AsyncRequestBody<'a>

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

Formats the value using the given formatter.

impl Default for AsyncRequestBody<'_>

fn default() -> Self

Returns the “default value” for a type.

impl<'a> From<&'a [u8]> for AsyncRequestBody<'a>

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

Converts to this type from the input type.

impl<'a> From<&'a mut AsyncRequestBody<'_>> for AsyncRequestBody<'a>

fn from(body: &'a mut AsyncRequestBody<'_>) -> Self

Converts to this type from the input type.

impl<'a> From<&'a str> for AsyncRequestBody<'a>

fn from(body: &'a str) -> Self

Converts to this type from the input type.

impl From<String> for AsyncRequestBody<'_>

fn from(body: String) -> Self

Converts to this type from the input type.

impl From<Vec<u8, Global>> for AsyncRequestBody<'_>

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

Converts to this type from the input type.