Lines Matching refs:buffered_amount
11 assert_eq!(s.buffered_amount(), 0); in test_stream_buffered_amount()
14 s.buffered_amount.store(8192, Ordering::SeqCst); in test_stream_buffered_amount()
16 assert_eq!(s.buffered_amount(), 8192, "unexpected bufferedAmount"); in test_stream_buffered_amount()
30 s.buffered_amount.store(4096, Ordering::SeqCst); 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()
48 assert_eq!(s.buffered_amount(), 3072, "unexpected bufferedAmount"); 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()
58 assert_eq!(s.buffered_amount(), 1024, "unexpected bufferedAmount"); 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()
68 assert_eq!(s.buffered_amount(), 0, "unexpected bufferedAmount"); in test_stream_amount_on_buffered_amount_low()
88 assert_eq!(s.buffered_amount(), 0); in test_stream()
99 assert_eq!(s.buffered_amount(), 6); in test_stream()
104 assert_eq!(s.buffered_amount(), 11); in test_stream()
163 assert_eq!(poll_stream.buffered_amount(), 0); in test_poll_stream()
171 assert_eq!(poll_stream.buffered_amount(), 3); in test_poll_stream()