Sha256: a3228f84142732d624e062bc933ac26267a10f71202123b3a9d5eebaba82eb96
Contents?: true
Size: 1.63 KB
Versions: 8
Compression:
Stored size: 1.63 KB
Contents
#![warn(rust_2018_idioms)] #![cfg(all(feature = "full", not(tokio_wasi)))] // Wasi does not support panic recovery use tokio::io::{split, AsyncRead, AsyncWrite, ReadBuf, ReadHalf, WriteHalf}; use std::io; use std::pin::Pin; use std::task::{Context, Poll}; struct RW; impl AsyncRead for RW { fn poll_read( self: Pin<&mut Self>, _cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<io::Result<()>> { buf.put_slice(&[b'z']); Poll::Ready(Ok(())) } } impl AsyncWrite for RW { fn poll_write( self: Pin<&mut Self>, _cx: &mut Context<'_>, _buf: &[u8], ) -> Poll<Result<usize, io::Error>> { Poll::Ready(Ok(1)) } fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { Poll::Ready(Ok(())) } fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { Poll::Ready(Ok(())) } } #[test] fn is_send_and_sync() { fn assert_bound<T: Send + Sync>() {} assert_bound::<ReadHalf<RW>>(); assert_bound::<WriteHalf<RW>>(); } #[test] fn split_stream_id() { let (r1, w1) = split(RW); let (r2, w2) = split(RW); assert!(r1.is_pair_of(&w1)); assert!(!r1.is_pair_of(&w2)); assert!(r2.is_pair_of(&w2)); assert!(!r2.is_pair_of(&w1)); } #[test] fn unsplit_ok() { let (r, w) = split(RW); r.unsplit(w); } #[test] #[should_panic] fn unsplit_err1() { let (r, _) = split(RW); let (_, w) = split(RW); r.unsplit(w); } #[test] #[should_panic] fn unsplit_err2() { let (_, w) = split(RW); let (r, _) = split(RW); r.unsplit(w); }
Version data entries
8 entries across 8 versions & 1 rubygems