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 fcd4332 commit 3e2e84cCopy full SHA for 3e2e84c
src/server.rs
@@ -296,8 +296,12 @@ impl<State: Send + Sync + 'static> Server<State> {
296
while let Some(stream) = incoming.next().await {
297
let stream = stream?;
298
let this = self.clone();
299
+ let local_addr = stream.local_addr().ok();
300
+ let peer_addr = stream.peer_addr().ok();
301
task::spawn(async move {
- let res = async_h1::accept(stream, |req| async {
302
+ let res = async_h1::accept(stream, |mut req| async {
303
+ req.set_local_addr(local_addr);
304
+ req.set_peer_addr(peer_addr);
305
let res = this.respond(req).await;
306
let res = res.map_err(|_| io::Error::from(io::ErrorKind::Other))?;
307
Ok(res)
0 commit comments