2 use futures::{Future, SinkExt, StreamExt, TryStreamExt, future, stream};
45             let mut results = stream::iter(results).buffer_unordered(MAX_CONCURRENCY);  in handle_request()
87             let mut stream =  in handle_request()  localVariable
90             while let Some(chunk) = stream.next().await {  in handle_request()
117                         let mut stream = executor::incoming_body(  in handle_request()  localVariable
138                             while let Some(chunk) = stream.next().await {  in handle_request()
207     let mut stream = executor::incoming_body(  in double_echo()  localVariable
214         while let Some(chunk) = stream.next().await {  in double_echo()
308     use futures::{Sink, Stream, future, sink, stream};
383                 if let Some((stream, body)) = self.0.take() {  in outgoing_body()
384                     drop(stream);  in outgoing_body()
390         let stream = body.write().expect("response body should be writable");  in outgoing_body()  localVariable
391         let pair = Rc::new(RefCell::new(Outgoing(Some((stream, body)))));  in outgoing_body()
402                         let (stream, _) = &pair.0.as_ref().unwrap();  in outgoing_body()
405                             match stream.check_write() {  in outgoing_body()
410                                         .push((stream.subscribe(), context.waker().clone()));  in outgoing_body()
419                                             stream.flush().expect("stream should be flushable");  in outgoing_body()
427                                         match stream.write(&chunk[offset..][..count]) {  in outgoing_body()
470                 stream: InputStream,  in incoming_body()
482                     Inner::Stream { stream, body } => {  in incoming_body()
483                         drop(stream);  in incoming_body()
491         stream::poll_fn({  in incoming_body()
492             let stream = body.stream().expect("response body should be readable");  in incoming_body()  localVariable
493             let mut incoming = Incoming(Inner::Stream { stream, body });  in incoming_body()
498                         Inner::Stream { stream, .. } => match stream.read(READ_SIZE) {  in incoming_body()
504                                         .push((stream.subscribe(), context.waker().clone()));  in incoming_body()
511                                 let Inner::Stream { stream, body } =  in incoming_body()
516                                 drop(stream);  in incoming_body()