159     let mut poll_stream = PollStream::new(s.clone());  in test_poll_stream()  localVariable
162     assert_eq!(poll_stream.stream_identifier(), 0);  in test_poll_stream()
163     assert_eq!(poll_stream.buffered_amount(), 0);  in test_poll_stream()
164     assert_eq!(poll_stream.buffered_amount_low_threshold(), 0);  in test_poll_stream()
165     assert_eq!(poll_stream.get_num_bytes_in_reassembly_queue().await, 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()
209     let clone = poll_stream.clone();  in test_poll_stream()
210     assert_eq!(clone.stream_identifier(), poll_stream.stream_identifier());  in test_poll_stream()