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,23 +9,25 @@
  * according to those terms.
  */
 
- use async_std::net::{TcpListener, TcpStream};
+//! WebSocket implementation of the Broker
- use async_std::sync::Mutex;
+
- use async_std::task;
+use async_std::net::{TcpListener, TcpStream};
- use async_tungstenite::accept_async;
+use async_std::sync::Mutex;
- use async_tungstenite::tungstenite::protocol::Message;
+use async_std::task;
- use debug_print::*;
+use async_tungstenite::accept_async;
- use futures::{SinkExt, StreamExt};
+use async_tungstenite::tungstenite::protocol::Message;
- use crate::broker_store_config::ConfigMode;
+use debug_print::*;
- use crate::server::*;
+use futures::{SinkExt, StreamExt};
- use p2p_stores_lmdb::broker_store::LmdbBrokerStore;
+use crate::broker_store_config::ConfigMode;
- use p2p_stores_lmdb::repo_store::LmdbRepoStore;
+use crate::server::*;
- use std::fs;
+use p2p_stores_lmdb::broker_store::LmdbBrokerStore;
- use std::sync::Arc;
+use p2p_stores_lmdb::repo_store::LmdbRepoStore;
- use tempfile::Builder;
+use std::fs;
- use std::{thread, time};
+use std::sync::Arc;
-
+use tempfile::Builder;
- pub async fn connection_loop(tcp: TcpStream, mut handler: ProtocolHandler) -> std::io::Result<()> {
+use std::{thread, time};
+
+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::*;