return Result from broker

Author: zvkemp

docs/src/tutorial/handling_disconnection.md

@@ -130,15 +130,15 @@ async fn server(addr: impl ToSocketAddrs) -> Result<()> {
     let listener = TcpListener::bind(addr).await?;
 
     let (broker_sender, broker_receiver) = mpsc::unbounded();
-    let broker = task::spawn(broker(broker_receiver));
+    let broker_handle = task::spawn(broker(broker_receiver));
     let mut incoming = listener.incoming();
     while let Some(stream) = incoming.next().await {
         let stream = stream?;
         println!("Accepting from: {}", stream.peer_addr()?);
         spawn_and_log_error(client(broker_sender.clone(), stream));
     }
     drop(broker_sender);
-    broker.await;
+    broker_handle.await;
     Ok(())
 }
 
@@ -260,6 +260,8 @@ async fn broker(mut events: Receiver<Event>) {
     drop(disconnect_sender); // 6
     while let Some((_name, _pending_messages)) = disconnect_receiver.next().await {
     }
+
+    Ok(())
 }
 
 fn spawn_and_log_error<F>(fut: F) -> task::JoinHandle<()>