Struct hyper::client::pool::PoolInner

struct PoolInner<T> {
    connecting: HashSet<(Scheme, Authority)>,
    idle: HashMap<(Scheme, Authority), Vec<Idle<T>>>,
    max_idle_per_host: usize,
    waiters: HashMap<(Scheme, Authority), VecDeque<Sender<T>>>,
    idle_interval_ref: Option<Sender<Infallible>>,
    exec: Exec,
    timeout: Option<Duration>,
}

Fields

connecting: HashSet<(Scheme, Authority)>

idle: HashMap<(Scheme, Authority), Vec<Idle<T>>>

max_idle_per_host: usize

waiters: HashMap<(Scheme, Authority), VecDeque<Sender<T>>>

idle_interval_ref: Option<Sender<Infallible>>

exec: Exec

timeout: Option<Duration>

Implementations

impl<T: Poolable> PoolInner<T>

fn put( &mut self, key: (Scheme, Authority), value: T, __pool_ref: &Arc<Mutex<PoolInner<T>>>, )

fn connected(&mut self, key: &(Scheme, Authority))

A Connecting task is complete. Not necessarily successfully, but the lock is going away, so clean up.

fn spawn_idle_interval(&mut self, pool_ref: &Arc<Mutex<PoolInner<T>>>)

impl<T> PoolInner<T>

fn clean_waiters(&mut self, key: &(Scheme, Authority))

Any FutureResponses that were created will have made a Checkout, and possibly inserted into the pool that it is waiting for an idle connection. If a user ever dropped that future, we need to clean out those parked senders.

impl<T: Poolable> PoolInner<T>

fn clear_expired(&mut self)

This should only be called by the IdleTask