interprocess-docfix 1.2.2

Interprocess communication toolkit. Docs fixed.
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

use {
    crate::os::unix::udsocket::{UdSocketPath, UdStream as SyncUdStream},
    std::{
        future::Future,
        io,
        pin::Pin,
        task::{Context, Poll},
    },
};

pub struct ConnectFuture<'a, 'b> {
    pub path: &'b UdSocketPath<'a>,
}
impl Future for ConnectFuture<'_, '_> {
    type Output = io::Result<SyncUdStream>;
    fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
        let path = self.get_mut().path;
        match SyncUdStream::connect_nonblocking(path) {
            Err(e) if e.kind() == io::ErrorKind::WouldBlock => {
                cx.waker().wake_by_ref();
                Poll::Pending
            }
            els => Poll::Ready(els),
        }
    }
}