ferriskey 0.6.1

Rust client for Valkey, built for FlowFabric. Forked from glide-core (valkey-glide).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use std::{io, time::Duration};

use crate::value::Error;
use futures_util::Future;

pub(crate) async fn timeout<F: Future>(
    duration: Duration,
    future: F,
) -> Result<F::Output, Elapsed> {
    ::tokio::time::timeout(duration, future)
        .await
        .map_err(|_| Elapsed(()))
}

#[derive(Debug)]
pub(crate) struct Elapsed(());

impl From<Elapsed> for Error {
    fn from(_: Elapsed) -> Self {
        io::Error::from(io::ErrorKind::TimedOut).into()
    }
}