Struct leaky_bucket::AcquireOwned
source · [−]pub struct AcquireOwned(_);
Expand description
The future associated with acquiring permits from a rate limiter using
RateLimiter::acquire_owned
.
Implementations
sourceimpl AcquireOwned
impl AcquireOwned
sourcepub fn is_core(&self) -> bool
pub fn is_core(&self) -> bool
Test if this acquire task is currently coordinating the rate limiter.
Examples
use leaky_bucket::RateLimiter;
use std::future::Future;
use std::sync::Arc;
use std::task::Context;
struct Waker;
let limiter = Arc::new(RateLimiter::builder().build());
let waker = Arc::new(Waker).into();
let mut cx = Context::from_waker(&waker);
let a1 = limiter.acquire_owned(1);
tokio::pin!(a1);
assert!(!a1.is_core());
assert!(a1.as_mut().poll(&mut cx).is_pending());
assert!(a1.is_core());
a1.as_mut().await;
// After completion this is no longer a core.
assert!(!a1.is_core());
Trait Implementations
sourceimpl Future for AcquireOwned
impl Future for AcquireOwned
Auto Trait Implementations
impl !RefUnwindSafe for AcquireOwned
impl Send for AcquireOwned
impl Sync for AcquireOwned
impl !Unpin for AcquireOwned
impl !UnwindSafe for AcquireOwned
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<F> IntoFuture for F where
F: Future,
impl<F> IntoFuture for F where
F: Future,
type IntoFuture = F
type IntoFuture = F
Which kind of future are we turning this into?
sourcefn into_future(self) -> <F as IntoFuture>::IntoFuture
fn into_future(self) -> <F as IntoFuture>::IntoFuture
Creates a future from a value. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more