Struct JoinFuture 

pub struct JoinFuture<'a, 'b, Q: ?Sized, Key, Val, We, B, L> {
    lifecycle: &'a L,
    shard: &'a RwLock<CacheShard<Key, Val, We, B, L, Arc<Placeholder<Val>>>>,
    state: JoinFutureState<'b, Q, Val>,
    notified: AtomicBool,
}

Future that results in an Ok(Value) or Err(Guard)

Fields

lifecycle: &'a L

shard: &'a RwLock<CacheShard<Key, Val, We, B, L, Arc<Placeholder<Val>>>>

state: JoinFutureState<'b, Q, Val>

notified: AtomicBool

Implementations

impl<'a, 'b, Q: ?Sized, Key, Val, We, B, L> JoinFuture<'a, 'b, Q, Key, Val, We, B, L>

pub fn new( lifecycle: &'a L, shard: &'a RwLock<CacheShard<Key, Val, We, B, L, Arc<Placeholder<Val>>>>, hash: u64, key: &'b Q, ) -> JoinFuture<'a, 'b, Q, Key, Val, We, B, L>

fn drop_pending_waiter(&mut self)

Trait Implementations

impl<Q: ?Sized, Key, Val, We, B, L> Drop for JoinFuture<'_, '_, Q, Key, Val, We, B, L>

fn drop(&mut self)

Executes the destructor for this type.

impl<'a, Key: Eq + Hash, Q: Hash + Equivalent<Key> + ToOwned<Owned = Key> + ?Sized, Val: Clone, We: Weighter<Key, Val>, B: BuildHasher, L: Lifecycle<Key, Val>> Future for JoinFuture<'a, '_, Q, Key, Val, We, B, L>

type Output = Result<Val, PlaceholderGuard<'a, Key, Val, We, B, L>>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.