pub struct WithCancellationTokenFutureOwned<F: Future> {
run_until_cancelled: Option<RunUntilCancelledFutureOwned<F>>,
}
Expand description
A Future
that is resolved once the corresponding CancellationToken
is cancelled or a given Future
gets resolved.
This future is immediately resolved if the corresponding CancellationToken
is already cancelled, otherwise, in case of concurrent completion and
cancellation, this is biased towards the future completion.
Fields§
§run_until_cancelled: Option<RunUntilCancelledFutureOwned<F>>
Implementations§
Source§impl<F: Future> WithCancellationTokenFutureOwned<F>
impl<F: Future> WithCancellationTokenFutureOwned<F>
pub(crate) fn new(cancellation_token: CancellationToken, future: F) -> Self
Trait Implementations§
Source§impl<F: Future> Future for WithCancellationTokenFutureOwned<F>
impl<F: Future> Future for WithCancellationTokenFutureOwned<F>
impl<'__pin, F: Future> Unpin for WithCancellationTokenFutureOwned<F>where
PinnedFieldsOf<__Origin<'__pin, F>>: Unpin,
Auto Trait Implementations§
impl<F> !Freeze for WithCancellationTokenFutureOwned<F>
impl<F> !RefUnwindSafe for WithCancellationTokenFutureOwned<F>
impl<F> Send for WithCancellationTokenFutureOwned<F>where
F: Send,
impl<F> Sync for WithCancellationTokenFutureOwned<F>where
F: Sync,
impl<F> !UnwindSafe for WithCancellationTokenFutureOwned<F>
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<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