clickhouse-rs 0.1.21

Tokio based asynchronous Yandex ClickHouse client library.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use tokio::prelude::*;

use crate::{errors::Error, pool::Pool, ClientHandle};

/// Future that resolves to a `ClientHandle`.
pub struct GetHandle {
    pool: Pool,
}

impl GetHandle {
    pub(crate) fn new(pool: &Pool) -> Self {
        Self { pool: pool.clone() }
    }
}

impl Future for GetHandle {
    type Item = ClientHandle;
    type Error = Error;

    fn poll(&mut self) -> Poll<Self::Item, Self::Error> {
        self.pool.poll()
    }
}