diff --git a/crdt-node/src/bft_crdt/mod.rs b/crdt-node/src/bft_crdt/mod.rs index c997b3c..8dbc346 100644 --- a/crdt-node/src/bft_crdt/mod.rs +++ b/crdt-node/src/bft_crdt/mod.rs @@ -6,7 +6,6 @@ use bft_json_crdt::{ use serde::{Deserialize, Serialize}; pub mod keys; -pub mod stdin; pub mod websocket; #[add_crdt_fields] diff --git a/crdt-node/src/lib.rs b/crdt-node/src/lib.rs index 1fbc08d..2db08a4 100644 --- a/crdt-node/src/lib.rs +++ b/crdt-node/src/lib.rs @@ -9,6 +9,7 @@ pub mod bft_crdt; pub(crate) mod cli; pub(crate) mod init; pub mod node; +mod stdin; pub mod utils; #[tokio::main] @@ -42,7 +43,7 @@ async fn setup(name: &String) -> SideNode { let (incoming_sender, incoming_receiver) = mpsc::channel::(32); let (stdin_sender, stdin_receiver) = std::sync::mpsc::channel(); task::spawn(async move { - bft_crdt::stdin::input(stdin_sender); + stdin::input(stdin_sender); }); // Wire the websocket client to the incoming channel diff --git a/crdt-node/src/bft_crdt/stdin.rs b/crdt-node/src/stdin.rs similarity index 100% rename from crdt-node/src/bft_crdt/stdin.rs rename to crdt-node/src/stdin.rs