more inline doc

p2p-broker/src/connection_local.rs

@@ -7,8 +7,7 @@
 // notice may not be copied, modified, or distributed except
 // according to those terms.
 
-//! Connection to a Broker, can be local or remote.
+//! Local Connection to a Broker
-//! If remote, it will use a Stream and Sink of framed messages
 
 use futures::{
     ready,

p2p-broker/src/server_ws.rs

@@ -9,6 +9,8 @@
  * according to those terms.
  */
 
+//! WebSocket implementation of the Broker
+
 use async_std::net::{TcpListener, TcpStream};
 use async_std::sync::Mutex;
 use async_std::task;
@@ -25,7 +27,7 @@
 use tempfile::Builder;
 use std::{thread, time};
 
- pub async fn connection_loop(tcp: TcpStream, mut handler: ProtocolHandler) -> std::io::Result<()> {
+async fn connection_loop(tcp: TcpStream, mut handler: ProtocolHandler) -> std::io::Result<()> {
     let mut ws = accept_async(tcp).await.unwrap();
     let (mut tx, mut rx) = ws.split();
 

p2p-client/src/connection_remote.rs

@@ -9,6 +9,8 @@
  * according to those terms.
 */
 
+//! Remote Connection to a Broker
+
 use async_std::task;
 use async_std::sync::Mutex;
 use futures::{

p2p-client/src/connection_ws.rs

@@ -9,6 +9,8 @@
  * according to those terms.
 */
 
+//! WebSocket Remote Connection to a Broker
+
 use debug_print::*;
 
 use p2p_repo::types::*;