diff --git a/src/engine/engine/mod.rs b/src/engine/engine/mod.rs index 6afa49f..e2c4235 100644 --- a/src/engine/engine/mod.rs +++ b/src/engine/engine/mod.rs @@ -1,5 +1,5 @@ -pub mod plugin; pub mod command; +pub mod plugin; use crate::{ engine::plugin::StrategyEngine, @@ -35,12 +35,6 @@ impl Engine { })) } - pub async fn spawn_terminal_server(&self) -> JoinHandle> { - let terminal_server = self.terminal_server.clone(); - - tokio::spawn(async move { terminal_server.run().await }) - } - pub async fn spawn_broadcaster(&self) -> JoinHandle> { let s = self.clone(); @@ -128,12 +122,6 @@ impl Engine { } } - pub async fn run_engine(&self) -> tokio::io::Result<()> { - loop { - tokio::time::sleep(tokio::time::Duration::from_millis(5000)).await; - } - } - pub async fn invalid_command_usage(&self, name: &str) -> tokio::io::Result<()> { self.terminal_server.error(name, "Invalid usage").await } diff --git a/src/engine/main.rs b/src/engine/main.rs index 7555ce1..1d45b2d 100644 --- a/src/engine/main.rs +++ b/src/engine/main.rs @@ -7,18 +7,13 @@ pub mod terminal; async fn main() -> anyhow::Result<()> { let engine = engine::Engine::new().await?; - let terminal_server = engine.spawn_terminal_server().await; - let broadcaster = engine.spawn_broadcaster().await; engine.strategy.spawn().await; - engine.run_engine().await?; + engine.terminal_server.run().await?; - let (terminal_server, broadcaster) = tokio::join!(terminal_server, broadcaster); - - terminal_server??; - broadcaster??; + broadcaster.await??; Ok(()) }