diff --git a/src/main.rs b/src/main.rs index 66e8163..d96749e 100644 --- a/src/main.rs +++ b/src/main.rs @@ -54,10 +54,10 @@ async fn main() -> Result<()> { info!("Starting everything up"); - tokio::try_join!( - post_indexer.start(), - profile_classifier.start(), - feed_server.serve(), + let _ = tokio::try_join!( + tokio::spawn(post_indexer.start()), + tokio::spawn(profile_classifier.start()), + tokio::spawn(feed_server.serve()), )?; Ok(()) diff --git a/src/processes/post_indexer.rs b/src/processes/post_indexer.rs index b55850d..547166d 100644 --- a/src/processes/post_indexer.rs +++ b/src/processes/post_indexer.rs @@ -34,7 +34,7 @@ impl PostIndexer { } impl PostIndexer { - pub async fn start(&self) -> Result<()> { + pub async fn start(self) -> Result<()> { info!("Starting"); loop { diff --git a/src/processes/profile_classifier.rs b/src/processes/profile_classifier.rs index 68db650..ac223ac 100644 --- a/src/processes/profile_classifier.rs +++ b/src/processes/profile_classifier.rs @@ -23,7 +23,7 @@ impl ProfileClassifier { } } - pub async fn start(&self) -> Result<()> { + pub async fn start(self) -> Result<()> { info!("Starting"); loop {