diff options
Diffstat (limited to 'tests/io_sync_bridge.rs')
-rw-r--r-- | tests/io_sync_bridge.rs | 62 |
1 files changed, 62 insertions, 0 deletions
diff --git a/tests/io_sync_bridge.rs b/tests/io_sync_bridge.rs new file mode 100644 index 0000000..76bbd0b --- /dev/null +++ b/tests/io_sync_bridge.rs @@ -0,0 +1,62 @@ +#![cfg(feature = "io-util")] +#![cfg(not(target_os = "wasi"))] // Wasi doesn't support threads + +use std::error::Error; +use std::io::{Cursor, Read, Result as IoResult, Write}; +use tokio::io::{AsyncRead, AsyncReadExt}; +use tokio_util::io::SyncIoBridge; + +async fn test_reader_len( + r: impl AsyncRead + Unpin + Send + 'static, + expected_len: usize, +) -> IoResult<()> { + let mut r = SyncIoBridge::new(r); + let res = tokio::task::spawn_blocking(move || { + let mut buf = Vec::new(); + r.read_to_end(&mut buf)?; + Ok::<_, std::io::Error>(buf) + }) + .await?; + assert_eq!(res?.len(), expected_len); + Ok(()) +} + +#[tokio::test] +async fn test_async_read_to_sync() -> Result<(), Box<dyn Error>> { + test_reader_len(tokio::io::empty(), 0).await?; + let buf = b"hello world"; + test_reader_len(Cursor::new(buf), buf.len()).await?; + Ok(()) +} + +#[tokio::test] +async fn test_async_write_to_sync() -> Result<(), Box<dyn Error>> { + let mut dest = Vec::new(); + let src = b"hello world"; + let dest = tokio::task::spawn_blocking(move || -> Result<_, String> { + let mut w = SyncIoBridge::new(Cursor::new(&mut dest)); + std::io::copy(&mut Cursor::new(src), &mut w).map_err(|e| e.to_string())?; + Ok(dest) + }) + .await??; + assert_eq!(dest.as_slice(), src); + Ok(()) +} + +#[tokio::test] +async fn test_shutdown() -> Result<(), Box<dyn Error>> { + let (s1, mut s2) = tokio::io::duplex(1024); + let (_rh, wh) = tokio::io::split(s1); + tokio::task::spawn_blocking(move || -> std::io::Result<_> { + let mut wh = SyncIoBridge::new(wh); + wh.write_all(b"hello")?; + wh.shutdown()?; + assert!(wh.write_all(b" world").is_err()); + Ok(()) + }) + .await??; + let mut buf = vec![]; + s2.read_to_end(&mut buf).await?; + assert_eq!(buf, b"hello"); + Ok(()) +} |