585     stream: Arc<Stream>,  field
606     pub fn new(stream: Arc<Stream>) -> Self {  in new()
608             stream,  in new()
619         self.stream  in into_inner()
625         self.stream.clone()  in clone_inner()
630         self.stream.stream_identifier  in stream_identifier()
635         self.stream.buffered_amount.load(Ordering::SeqCst)  in buffered_amount()
641         self.stream.buffered_amount_low.load(Ordering::SeqCst)  in buffered_amount_low_threshold()
648         let reassembly_queue = self.stream.reassembly_queue.lock().await;  in get_num_bytes_in_reassembly_queue()
672                 let stream = self.stream.clone();  in poll_read()  localVariable
675                     stream.read(temp_buf.as_mut_slice()).await.map(|n| {  in poll_read()
743                     let stream = self.stream.clone();  in poll_write()  localVariable
745                     self.write_fut = Some(Box::pin(async move { stream.write(&bytes).await }));  in poll_write()
753                     let stream = self.stream.clone();  in poll_write()  localVariable
755                     self.write_fut = Some(Box::pin(async move { stream.write(&bytes).await }));  in poll_write()
760             let stream = self.stream.clone();  in poll_write()  localVariable
764                 .insert(Box::pin(async move { stream.write(&bytes).await }));  in poll_write()
814                 let stream = self.stream.clone();  in poll_shutdown()  localVariable
816                     stream.shutdown(Shutdown::Write).await  in poll_shutdown()
845             .field("stream", &self.stream)  in fmt()
853         &self.stream  in as_ref()