#[test]
fn r1_host_input_drains_a_buffer_per_wakeup() -> anyhow::Result<()> {
use std::io::Write as _;
let (mut writer, reader) = std::os::unix::net::UnixStream::pair()?;
writer.write_all(&[0; 8192])?;
drop(writer);
assert_eq!(
super::read_once(&reader, &mut [0; 8192])?,
8192,
"one wake must drain the buffered host input"
);
assert_eq!(super::read_once(&reader, &mut [0; 8192])?, 0);
Ok(())
}