We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ba4327e commit c251845Copy full SHA for c251845
axum/src/serve/mod.rs
@@ -3,7 +3,7 @@
3
use std::{
4
convert::Infallible,
5
fmt::Debug,
6
- future::{poll_fn, Future, IntoFuture},
+ future::{Future, IntoFuture},
7
io,
8
marker::PhantomData,
9
pin::pin,
@@ -308,7 +308,8 @@ where
308
309
trace!("connection {remote_addr:?} accepted");
310
311
- poll_fn(|cx| make_service.poll_ready(cx))
+ make_service
312
+ .ready()
313
.await
314
.unwrap_or_else(|err| match err {});
315
@@ -322,9 +323,7 @@ where
322
323
.map_request(|req: Request<Incoming>| req.map(Body::new));
324
325
let hyper_service = TowerToHyperService::new(tower_service);
-
326
let signal_tx = signal_tx.clone();
327
328
let close_rx = close_rx.clone();
329
330
tokio::spawn(async move {
0 commit comments