async_bincode/
futures.rs

1//! Asynchronous access to a bincode-encoded item stream using `futures_io`. See the top-level
2//! documentation and the documentation for [`AsyncBincodeReader`], [`AsyncBincodeWriter`], and
3//! [`AsyncBincodeStream`].
4
5make_reader!(futures_io::AsyncRead, internal_poll_reader);
6make_writer!(futures_io::AsyncWrite, poll_close);
7make_stream!(futures_io::AsyncRead, futures_io::AsyncWrite, [u8], usize);
8
9fn internal_poll_reader<R>(
10    r: std::pin::Pin<&mut R>,
11    cx: &mut std::task::Context,
12    rest: &mut [u8],
13) -> std::task::Poll<std::io::Result<usize>>
14where
15    R: futures_io::AsyncRead + Unpin,
16{
17    r.poll_read(cx, rest)
18}