tokio-util 0.7.18

Additional utilities for working with Tokio.
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
30
31

mod maybe_dangling;
#[cfg(any(feature = "io", feature = "codec"))]
mod poll_buf;

pub(crate) use maybe_dangling::MaybeDangling;
#[cfg(any(feature = "io", feature = "codec"))]
#[cfg_attr(not(feature = "io"), allow(unreachable_pub))]
pub use poll_buf::{poll_read_buf, poll_write_buf};

cfg_rt! {
    #[cfg_attr(not(feature = "io"), allow(unused))]
    pub(crate) use tokio::task::coop::poll_proceed;
}

cfg_not_rt! {
    #[cfg_attr(not(feature = "io"), allow(unused))]
    use std::task::{Context, Poll};

    #[cfg_attr(not(feature = "io"), allow(unused))]
    pub(crate) struct RestoreOnPending;

    #[cfg_attr(not(feature = "io"), allow(unused))]
    impl RestoreOnPending {
        pub(crate) fn made_progress(&self) {}
    }

    #[cfg_attr(not(feature = "io"), allow(unused))]
    pub(crate) fn poll_proceed(_cx: &mut Context<'_>) -> Poll<RestoreOnPending> {
        Poll::Ready(RestoreOnPending)
    }
}