mysql_async_support_rt 0.3.0

Supporting types for interacting with mysql databases.
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

use mysql_async::Pool;
use mysql_async_support_model::Error;

/// Trait for an async function with a restricted lifetime scope.
pub trait FnWithPool<'pool> {
    type Output;
    type Error: From<Error>;
    type Fut: std::future::Future<Output = (Pool, Result<Self::Output, Self::Error>)> + 'pool;

    /// Runs the function
    fn call(self, pool: Pool) -> Self::Fut;
}

impl<'pool, F, Fut, T, E> FnWithPool<'pool> for F
where
    F: FnOnce(Pool) -> Fut,
    E: From<Error>,
    Fut: std::future::Future<Output = (Pool, Result<T, E>)> + 'pool,
{
    type Error = E;
    type Fut = Fut;
    type Output = T;

    fn call(self, pool: Pool) -> Fut {
        self(pool)
    }
}