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 33c0348 commit de45a9fCopy full SHA for de45a9f
src/asynchronous/server.rs
@@ -171,13 +171,13 @@ impl Server {
171
Ok(())
172
}
173
174
- pub fn accept(&mut self, conn: Socket) -> Connection<impl Builder> {
+ pub async fn accept(&mut self, conn: Socket) -> std::io::Result<()> {
175
let delegate = ServerBuilder {
176
services: self.services.clone(),
177
streams: Arc::default(),
178
shutdown_waiter: self.shutdown.subscribe(),
179
};
180
- Connection::new(conn, delegate)
+ Connection::new(conn, delegate).run().await
181
182
183
pub async fn shutdown(&mut self) -> Result<()> {
0 commit comments