446     close_f: BatchFuture,  field
452     fn new(call: Call, close_f: BatchFuture) -> ShareCall {  in new()
455             close_f,  in new()
465         let res = match Pin::new(&mut self.close_f).poll(cx) {  in poll_finish()
489         task::check_alive(&self.close_f)  in check_alive()
513     close_f: Option<BatchFuture>,  field
519     fn new(close_f: Option<BatchFuture>) -> StreamingBase {  in new()
521             close_f,  in new()
535             if let Some(close_f) = &mut self.close_f {  in poll()
536                 if Pin::new(close_f).poll(cx)?.is_ready() {  in poll()
542                 self.close_f.take();  in poll()
557             if self.close_f.is_none() {  in poll()
577         if !self.read_done || self.close_f.is_some() {  in on_drop()