pub(crate) struct PipeToSendStream<S>where
S: Body,{
body_tx: SendStream<SendBuf<S::Data>>,
data_done: bool,
stream: S,
}
Fields§
§body_tx: SendStream<SendBuf<S::Data>>
§data_done: bool
§stream: S
Implementations§
Source§impl<S> PipeToSendStream<S>where
S: Body,
impl<S> PipeToSendStream<S>where
S: Body,
fn new(stream: S, tx: SendStream<SendBuf<S::Data>>) -> PipeToSendStream<S> ⓘ
Trait Implementations§
Source§impl<S> Future for PipeToSendStream<S>
impl<S> Future for PipeToSendStream<S>
impl<'__pin, S> Unpin for PipeToSendStream<S>
Auto Trait Implementations§
impl<S> Freeze for PipeToSendStream<S>where
S: Freeze,
impl<S> RefUnwindSafe for PipeToSendStream<S>where
S: RefUnwindSafe,
impl<S> Send for PipeToSendStream<S>
impl<S> Sync for PipeToSendStream<S>
impl<S> UnwindSafe for PipeToSendStream<S>where
S: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_cancellation_token(
self,
cancellation_token: &CancellationToken,
) -> WithCancellationTokenFuture<'_, Self>where
Self: Sized,
fn with_cancellation_token(
self,
cancellation_token: &CancellationToken,
) -> WithCancellationTokenFuture<'_, Self>where
Self: Sized,
Similar to
CancellationToken::run_until_cancelled
,
but with the advantage that it is easier to write fluent call chains,
and biased towards waiting for CancellationToken
to complete. Read moreSource§fn with_cancellation_token_owned(
self,
cancellation_token: CancellationToken,
) -> WithCancellationTokenFutureOwned<Self>where
Self: Sized,
fn with_cancellation_token_owned(
self,
cancellation_token: CancellationToken,
) -> WithCancellationTokenFutureOwned<Self>where
Self: Sized,
Similar to
CancellationToken::run_until_cancelled_owned
,
but with the advantage that it is easier to write fluent call chains,
and biased towards waiting for CancellationToken
to complete. Read moreSource§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<F> IntoFuture for Fwhere
F: Future,
impl<F> IntoFuture for Fwhere
F: Future,
Source§type IntoFuture = F
type IntoFuture = F
Which kind of future are we turning this into?
Source§fn into_future(self) -> <F as IntoFuture>::IntoFuture
fn into_future(self) -> <F as IntoFuture>::IntoFuture
Creates a future from a value. Read more