[−][src]Struct tower_grpc::codegen::server::grpc::BoxBody
Dynamic Send
body object.
Methods
impl BoxBody
[src]
pub fn new(
inner: Box<dyn Body<Data = <Bytes as IntoBuf>::Buf, Error = Status> + Send>
) -> Self
[src]
inner: Box<dyn Body<Data = <Bytes as IntoBuf>::Buf, Error = Status> + Send>
) -> Self
Create a new BoxBody
backed by inner
.
pub fn map_from<B>(inner: B) -> Self where
B: Body + Send + 'static,
B::Data: Into<Bytes>,
[src]
B: Body + Send + 'static,
B::Data: Into<Bytes>,
Create a new BoxBody
mapping item and error to the default types.
Trait Implementations
impl<T, U> Encodable<BoxBody> for T where
T: Stream<Item = U, Error = Status> + Send + 'static,
U: Message + 'static,
[src]
T: Stream<Item = U, Error = Status> + Send + 'static,
U: Message + 'static,
fn into_encode(self) -> BoxBody
[src]
impl Debug for BoxBody
[src]
impl Body for BoxBody
[src]
type Data = <Bytes as IntoBuf>::Buf
Values yielded by the Body
.
type Error = Status
The error type this BufStream
might generate.
fn is_end_stream(&self) -> bool
[src]
fn poll_data(&mut self) -> Poll<Option<Self::Data>, Self::Error>
[src]
fn poll_trailers(&mut self) -> Poll<Option<HeaderMap>, Self::Error>
[src]
fn size_hint(&self) -> SizeHint
[src]
Returns the bounds on the remaining length of the stream. Read more
Auto Trait Implementations
impl Unpin for BoxBody
impl !Sync for BoxBody
impl Send for BoxBody
impl !UnwindSafe for BoxBody
impl !RefUnwindSafe for BoxBody
Blanket Implementations
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Body for T where
T: BufStream,
[src]
T: BufStream,
type Data = <T as BufStream>::Item
Values yielded by the Body
.
type Error = <T as BufStream>::Error
The error type this BufStream
might generate.
fn poll_data(
&mut self
) -> Result<Async<Option<<T as Body>::Data>>, <T as Body>::Error>
[src]
&mut self
) -> Result<Async<Option<<T as Body>::Data>>, <T as Body>::Error>
fn size_hint(&self) -> SizeHint
[src]
fn poll_trailers(
&mut self
) -> Result<Async<Option<HeaderMap<HeaderValue>>>, <T as Body>::Error>
[src]
&mut self
) -> Result<Async<Option<HeaderMap<HeaderValue>>>, <T as Body>::Error>
fn is_end_stream(&self) -> bool
[src]
impl<T> BodyExt for T where
T: Body,
[src]
T: Body,
fn into_buf_stream(self) -> IntoBufStream<Self>
[src]
Wrap the Body
so that it implements tokio_buf::BufStream directly.
impl<T, U> Encodable<BoxBody> for T where
T: Stream<Item = U, Error = Status> + Send + 'static,
U: Message + 'static,
[src]
T: Stream<Item = U, Error = Status> + Send + 'static,
U: Message + 'static,
fn into_encode(Self) -> BoxBody
[src]
impl<T, U> Encodable<BoxBody> for T where
T: Stream<Item = U, Error = Status> + Send + 'static,
U: Message + 'static,
[src]
T: Stream<Item = U, Error = Status> + Send + 'static,
U: Message + 'static,