Skip to content

Commit 6d6328a

Browse files
zvkempStjepan Glavina
authored and
Stjepan Glavina
committed
use broker_handle to avoid overloading the broker fn (#100)
1 parent 794c12f commit 6d6328a

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

docs/src/tutorial/clean_shutdown.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,15 +25,15 @@ async fn server(addr: impl ToSocketAddrs) -> Result<()> {
2525
let listener = TcpListener::bind(addr).await?;
2626

2727
let (broker_sender, broker_receiver) = mpsc::unbounded();
28-
let broker = task::spawn(broker(broker_receiver));
28+
let broker_handle = task::spawn(broker(broker_receiver));
2929
let mut incoming = listener.incoming();
3030
while let Some(stream) = incoming.next().await {
3131
let stream = stream?;
3232
println!("Accepting from: {}", stream.peer_addr()?);
3333
spawn_and_log_error(client(broker_sender.clone(), stream));
3434
}
3535
drop(broker_sender); // 1
36-
broker.await?; // 5
36+
broker_handle.await?; // 5
3737
Ok(())
3838
}
3939
```

docs/src/tutorial/handling_disconnection.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -130,15 +130,15 @@ async fn server(addr: impl ToSocketAddrs) -> Result<()> {
130130
let listener = TcpListener::bind(addr).await?;
131131

132132
let (broker_sender, broker_receiver) = mpsc::unbounded();
133-
let broker = task::spawn(broker(broker_receiver));
133+
let broker_handle = task::spawn(broker(broker_receiver));
134134
let mut incoming = listener.incoming();
135135
while let Some(stream) = incoming.next().await {
136136
let stream = stream?;
137137
println!("Accepting from: {}", stream.peer_addr()?);
138138
spawn_and_log_error(client(broker_sender.clone(), stream));
139139
}
140140
drop(broker_sender);
141-
broker.await;
141+
broker_handle.await;
142142
Ok(())
143143
}
144144

0 commit comments

Comments
 (0)