Lines Matching refs:executor
17 executor::run(async move { in handle()
52 executor::outgoing_body(response.body().expect("response should be writable")); in handle_request()
83 executor::outgoing_body(response.body().expect("response should be writable")); in handle_request()
88 executor::incoming_body(request.consume().expect("request should be readable")); in handle_request()
117 let mut stream = executor::incoming_body( in handle_request()
131 let mut body = executor::outgoing_body( in handle_request()
199 let mut body = executor::outgoing_body( in double_echo()
205 let response = executor::outgoing_request_send(outgoing_request); in double_echo()
207 let mut stream = executor::incoming_body( in double_echo()
281 let response = executor::outgoing_request_send(request).await?; in hash()
290 executor::incoming_body(response.consume().expect("response should be readable")); in hash()
306 mod executor { module