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.
FutureExt::boxed
1 parent 69c15ca commit d406602Copy full SHA for d406602
src/server/tcp.rs
@@ -106,10 +106,11 @@ impl AddrIncoming {
106
}
107
self.timeout = None;
108
109
- let mut accept_fut = self.listener.accept().boxed();
+ let accept = self.listener.accept();
110
+ futures_util::pin_mut!(accept);
111
112
loop {
- match accept_fut.poll_unpin(cx) {
113
+ match accept.poll_unpin(cx) {
114
Poll::Ready(Ok((socket, addr))) => {
115
if let Some(dur) = self.tcp_keepalive_timeout {
116
if let Err(e) = socket.set_keepalive(Some(dur)) {
0 commit comments