Skip to content

Commit 77c7bfe

Browse files
Fix server to run in Tokio environment
1 parent f768b19 commit 77c7bfe

File tree

1 file changed

+14
-18
lines changed

1 file changed

+14
-18
lines changed

src/bin/rla-server.rs

Lines changed: 14 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -115,24 +115,20 @@ fn main() {
115115
process::exit(0);
116116
});
117117

118-
let s = service.clone();
119-
let server =
120-
hyper::server::Server::bind(&addr).serve(hyper::service::make_service_fn(move |_| {
121-
let s = s.clone();
122-
async move {
123-
Ok::<_, hyper::Error>(hyper::service::service_fn(move |req| {
124-
let s = s.clone();
125-
async move { s.call(req).await }
126-
}))
127-
}
128-
}));
129-
130-
tokio::runtime::Runtime::new()?
131-
.block_on(server)
132-
.map_err(|e| {
133-
error!("server error: {}", e);
134-
e
135-
})?;
118+
tokio::runtime::Runtime::new()?.block_on(async move {
119+
let s = service.clone();
120+
hyper::server::Server::bind(&addr)
121+
.serve(hyper::service::make_service_fn(move |_| {
122+
let s = s.clone();
123+
async move {
124+
Ok::<_, hyper::Error>(hyper::service::service_fn(move |req| {
125+
let s = s.clone();
126+
async move { s.call(req).await }
127+
}))
128+
}
129+
}))
130+
.await
131+
})?;
136132

137133
Ok(())
138134
});

0 commit comments

Comments
 (0)