dave/bft-crdt-experiment
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Moved the crdt stdin listener to into the CRDT module

Browse Source
This commit is contained in:
Dave Hrycyszyn
2024-06-27 11:06:39 +01:00
parent 3595675d41
commit e5c9c1364c
3 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
side-node/src/bft_crdt/mod.rs
View File

@@ -6,6 +6,7 @@ use bft_json_crdt::{
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
pub mod keys; pub mod keys;
pub mod stdin;
pub mod websocket; pub mod websocket;
#[add_crdt_fields] #[add_crdt_fields]

0
side-node/src/stdin.rs → side-node/src/bft_crdt/stdin.rs
View File

3
side-node/src/lib.rs
View File

@@ -10,7 +10,6 @@ pub mod bitcoin;
pub(crate) mod cli; pub(crate) mod cli;
pub(crate) mod init; pub(crate) mod init;
pub mod node; pub mod node;
pub(crate) mod stdin;
pub mod utils; pub mod utils;
#[tokio::main] #[tokio::main]
@@ -49,7 +48,7 @@ async fn setup(name: &String) -> SideNode {
let (incoming_sender, incoming_receiver) = mpsc::channel::<SignedOp>(32); let (incoming_sender, incoming_receiver) = mpsc::channel::<SignedOp>(32);
let (stdin_sender, stdin_receiver) = std::sync::mpsc::channel(); let (stdin_sender, stdin_receiver) = std::sync::mpsc::channel();
task::spawn(async move { task::spawn(async move {
stdin::input(stdin_sender); bft_crdt::stdin::input(stdin_sender);
}); });
// Finally, create the node and return it // Finally, create the node and return it