9     let s = Stream::default();  in test_stream_buffered_amount()  localVariable
11     assert_eq!(s.buffered_amount(), 0);  in test_stream_buffered_amount()
12     assert_eq!(s.buffered_amount_low_threshold(), 0);  in test_stream_buffered_amount()
14     s.buffered_amount.store(8192, Ordering::SeqCst);  in test_stream_buffered_amount()
15     s.set_buffered_amount_low_threshold(2048);  in test_stream_buffered_amount()
16     assert_eq!(s.buffered_amount(), 8192, "unexpected bufferedAmount");  in test_stream_buffered_amount()
18         s.buffered_amount_low_threshold(),  in test_stream_buffered_amount()
28     let s = Stream::default();  in test_stream_amount_on_buffered_amount_low()  localVariable
30     s.buffered_amount.store(4096, Ordering::SeqCst);  in test_stream_amount_on_buffered_amount_low()
31     s.set_buffered_amount_low_threshold(2048);  in test_stream_amount_on_buffered_amount_low()
36     s.on_buffered_amount_low(Box::new(move || {  in test_stream_amount_on_buffered_amount_low()
42     s.on_buffer_released(-32).await; // bufferedAmount = 3072  in test_stream_amount_on_buffered_amount_low()
43     assert_eq!(s.buffered_amount(), 4096, "unexpected bufferedAmount");  in test_stream_amount_on_buffered_amount_low()
47     s.on_buffer_released(1024).await; // bufferedAmount = 3072  in test_stream_amount_on_buffered_amount_low()
48     assert_eq!(s.buffered_amount(), 3072, "unexpected bufferedAmount");  in test_stream_amount_on_buffered_amount_low()
52     s.on_buffer_released(1024).await; // bufferedAmount = 2048  in test_stream_amount_on_buffered_amount_low()
53     assert_eq!(s.buffered_amount(), 2048, "unexpected bufferedAmount");  in test_stream_amount_on_buffered_amount_low()
57     s.on_buffer_released(1024).await; // bufferedAmount = 1024  in test_stream_amount_on_buffered_amount_low()
58     assert_eq!(s.buffered_amount(), 1024, "unexpected bufferedAmount");  in test_stream_amount_on_buffered_amount_low()
62     s.on_buffer_released(1024).await; // bufferedAmount = 0  in test_stream_amount_on_buffered_amount_low()
63     assert_eq!(s.buffered_amount(), 0, "unexpected bufferedAmount");  in test_stream_amount_on_buffered_amount_low()
67     s.on_buffer_released(1024).await; // bufferedAmount = 0  in test_stream_amount_on_buffered_amount_low()
68     assert_eq!(s.buffered_amount(), 0, "unexpected bufferedAmount");  in test_stream_amount_on_buffered_amount_low()
76     let s = Stream::new(  in test_stream()  localVariable
87     assert_eq!(s.stream_identifier(), 0);  in test_stream()
88     assert_eq!(s.buffered_amount(), 0);  in test_stream()
89     assert_eq!(s.buffered_amount_low_threshold(), 0);  in test_stream()
90     assert_eq!(s.get_num_bytes_in_reassembly_queue().await, 0);  in test_stream()
93     s.set_default_payload_type(PayloadProtocolIdentifier::Binary);  in test_stream()
94     s.set_reliability_params(true, ReliabilityType::Reliable, 0);  in test_stream()
97     let n = s.write(&Bytes::from("Hello ")).await?;  in test_stream()
99     assert_eq!(s.buffered_amount(), 6);  in test_stream()
100     let n = s  in test_stream()
104     assert_eq!(s.buffered_amount(), 11);  in test_stream()
108     s.handle_data(ChunkPayloadData {  in test_stream()
119     s.read(&mut buf).await?;  in test_stream()
123     s.shutdown(Shutdown::Write).await?;  in test_stream()
125     assert!(s.write(&Bytes::from("error")).await.is_err());  in test_stream()
127     s.handle_data(ChunkPayloadData {  in test_stream()
137     s.read(&mut buf).await?;  in test_stream()
141     s.shutdown(Shutdown::Read).await?;  in test_stream()
143     assert_eq!(s.read(&mut buf).await, Ok(0));  in test_stream()
150     let s = Arc::new(Stream::new(  in test_poll_stream()  localVariable
159     let mut poll_stream = PollStream::new(s.clone());  in test_poll_stream()
175     let sc = s.clone();  in test_poll_stream()