Searched refs:poll_stream (Results 1 – 1 of 1) sorted by relevance
159 let mut poll_stream = PollStream::new(s.clone()); in test_poll_stream() localVariable162 assert_eq!(poll_stream.stream_identifier(), 0); in test_poll_stream()163 assert_eq!(poll_stream.buffered_amount(), 0); in test_poll_stream()168 let n = poll_stream.write(&[1, 2, 3]).await?; in test_poll_stream()170 poll_stream.flush().await?; in test_poll_stream()171 assert_eq!(poll_stream.buffered_amount(), 3); in test_poll_stream()187 poll_stream.read_exact(&mut buf).await?; in test_poll_stream()191 poll_stream.shutdown().await?; in test_poll_stream()193 assert!(poll_stream.write(&[1, 2, 3]).await.is_err()); in test_poll_stream()205 poll_stream.read_exact(&mut buf).await?; in test_poll_stream()[all …]