monoio 0.2.4

A thread per core runtime based on iouring.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use std::future::Future;

use super::Sink;

/// Sink extensions.
pub trait SinkExt<T>: Sink<T> {
    /// Send and flush.
    fn send_and_flush(&mut self, item: T) -> impl Future<Output = Result<(), Self::Error>>;
}

impl<T, A> SinkExt<T> for A
where
    A: Sink<T>,
{
    async fn send_and_flush(&mut self, item: T) -> Result<(), Self::Error> {
        Sink::<T>::send(self, item).await?;
        Sink::<T>::flush(self).await
    }
}