limit public api a bit

src/connection/filter.rs

@@ -47,6 +47,7 @@ impl<T: Clone> RingBuffer<T> {
     }
 }
 
+/// A filter for incoming messages, allowing listing by message type, job id and notifications
 #[derive(Clone)]
 pub struct MessageFilter {
     job_id_filters: Arc<DashMap<JobId, oneshot::Sender<RawNetMessage>>>,

src/connection/mod.rs

@@ -1,6 +1,6 @@
 mod filter;
-pub mod raw;
-pub mod unauthenticated;
+pub(crate) mod raw;
+pub(crate) mod unauthenticated;
 
 use crate::auth::{AuthConfirmationHandler, GuardDataStore};
 use crate::message::{
@@ -11,7 +11,7 @@ use crate::serverlist::ServerList;
 use crate::service_method::ServiceMethodRequest;
 use crate::session::{ConnectionError, Session};
 use async_stream::try_stream;
-pub use filter::MessageFilter;
+pub(crate) use filter::MessageFilter;
 use futures_util::{FutureExt, Sink, SinkExt};
 use raw::RawConnection;
 use std::fmt::{Debug, Formatter};
@@ -34,7 +34,7 @@ type TransportWriter = Arc<Mutex<dyn Sink<RawNetMessage, Error = NetworkError> +
 
 /// Send raw messages to steam
 #[derive(Clone)]
-pub struct MessageSender {
+pub(crate) struct MessageSender {
     write: TransportWriter,
 }
 

src/connection/unauthenticated.rs

@@ -18,6 +18,7 @@ use tokio_stream::wrappers::BroadcastStream;
 use tokio_stream::StreamExt;
 use tracing::{debug, error};
 
+/// A Connection that hasn't been authentication yet
 pub struct UnAuthenticatedConnection(RawConnection);
 
 impl UnAuthenticatedConnection {