Skip to content
This repository was archived by the owner on Sep 5, 2019. It is now read-only.

Commit f412ab2

Browse files
committed
client_writer_loop -> connection_writer_loop
1 parent 729686e commit f412ab2

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/bin/server.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ async fn connection_loop(mut broker: Sender<Event>, stream: TcpStream) -> Result
8080
Ok(())
8181
}
8282

83-
async fn client_writer_loop(
83+
async fn connection_writer_loop(
8484
messages: &mut Receiver<String>,
8585
stream: Arc<TcpStream>,
8686
mut shutdown: Receiver<Void>,
@@ -149,7 +149,7 @@ async fn broker_loop(mut events: Receiver<Event>) {
149149
entry.insert(client_sender);
150150
let mut disconnect_sender = disconnect_sender.clone();
151151
spawn_and_log_error(async move {
152-
let res = client_writer_loop(&mut client_receiver, stream, shutdown).await;
152+
let res = connection_writer_loop(&mut client_receiver, stream, shutdown).await;
153153
disconnect_sender.send((name, client_receiver)).await
154154
.unwrap();
155155
res

0 commit comments

Comments
 (0)