1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

//! Types and utilities for working with `Body`.

mod into_buf_stream;

pub use self::into_buf_stream::IntoBufStream;

use http_body::Body;

/// An extension trait for `Body` providing additional adapters.
pub trait BodyExt: Body {
    /// Wrap the `Body` so that it implements tokio_buf::BufStream directly.
    fn into_buf_stream(self) -> IntoBufStream<Self>
    where
        Self: Sized,
    {
        IntoBufStream::new(self)
    }
}

impl<T: Body> BodyExt for T {}