guilhermewerner/mini-redis
1
0
Fork 0
mirror of https://github.com/guilhermewerner/mini-redis synced 2025-06-16 15:05:39 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add Concurrency to Server

Browse Source
This commit is contained in:
GuilhermeWerner
2021-01-19 12:15:32 -03:00
parent 3d6239e514
commit 4a2a783205
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
Source/Server.rs
View File

@ -9,7 +9,12 @@ async fn main() {
loop { loop {
// The second item contains the IP and port of the new connection. // The second item contains the IP and port of the new connection.
let (socket, _) = listener.accept().await.unwrap(); let (socket, _) = listener.accept().await.unwrap();
// A new task is spawned for each inbound socket. The socket is
// moved to the new task and processed there.
tokio::spawn(async move {
process(socket).await; process(socket).await;
});
} }
} }