hyper-client-pool 0.6.0

Pooled Hyper Async Clients
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use raii_counter::WeakCounter;

pub struct TransactionCounter {
    transaction_counter: WeakCounter,
    worker_counter: WeakCounter,
}

impl TransactionCounter {
    pub(crate) fn new(
        transaction_counter: WeakCounter,
        worker_counter: WeakCounter,
    ) -> TransactionCounter {
        TransactionCounter {
            transaction_counter,
            worker_counter,
        }
    }

    /// Get the count of transactions
    pub fn count(&self) -> usize {
        self.transaction_counter.count()
    }

    /// Checks that the Worker is still alive
    /// The strong counter is held by the Worker
    pub fn is_valid(&self) -> bool {
        self.worker_counter.count() > 0
    }
}