tweak public interface

src/connectors/handler.rs

@@ -3,7 +3,7 @@ use crate::providers::Endpoints;
 use std::{fmt::Debug, future::Future};
 pub(crate) use tokio_tungstenite::tungstenite::protocol::Message;
 
-pub(crate) trait EventHandler<Monitorable> {
+pub trait EventHandler<Monitorable> {
     type Error: Debug;
     type Context;
     type Update;

src/monitor/depth.rs

@@ -53,7 +53,10 @@ impl super::Monitor for DepthConfig {
                 >(
                     provider,
                     tx,
-                    self.symbols.iter().map(|s| s.to_uppercase()).collect(),
+                    self.symbols
+                        .iter()
+                        .map(|s| s.to_uppercase())
+                        .collect::<Vec<_>>(),
                 )
                 .await
             })

src/monitor/mod.rs

@@ -1,5 +1,5 @@
 mod depth;
-mod order_book;
+pub mod order_book;
 
 use clap::{Subcommand, ValueEnum};
 pub use depth::{Depth, DepthConfig, DepthHandler, DepthUpdate};

src/net/mod.rs

@@ -1,4 +1,4 @@
 pub(crate) mod streaming;
 pub(crate) mod ws_adapter;
 
-pub use streaming::Message;
+pub use streaming::{Message, MultiSymbolStream};

src/net/streaming.rs

@@ -12,24 +12,24 @@ use tokio_tungstenite::WebSocketStream;
 use tracing::debug;
 use tracing::{error, info};
 
-pub(crate) struct MultiSymbolStream;
+pub struct MultiSymbolStream;
 
 impl MultiSymbolStream {
-    pub(crate) async fn stream<Monitorable, Handle, P, Context>(
+    pub async fn stream<Monitorable, Handle, P, Context>(
         provider: P,
         context: Context,
-        symbols: Vec<String>,
+        symbols: impl AsRef<[String]>,
     ) where
         P: Endpoints<Monitorable> + Sync + Clone + 'static,
         Context: Sync + Clone + 'static,
         Handle: EventHandler<Monitorable, Context = Context> + 'static,
     {
         let ctrl_c = Terminate::new();
 
-        let mut stream = Self::subscribe(&provider, &symbols).await;
+        let mut stream = Self::subscribe(&provider, symbols.as_ref()).await;
 
         let mut handler =
-            MonitorMultiplexor::<Handle, Monitorable>::build(provider, &symbols, context)
+            MonitorMultiplexor::<Handle, Monitorable>::build(provider, symbols.as_ref(), context)
                 .await
                 .unwrap();