From 5c99d2ce5c1bdfb8811b445c9f37fd24df6fa02e Mon Sep 17 00:00:00 2001
From: Brandon Thomas <echelon@gmail.com>
Date: Mon, 28 Sep 2020 03:22:08 -0400
Subject: [PATCH] Reducing workers seemed to work; (I was starving them?)

---
 src/main.rs | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 7f0bdd2854..c94c667ab3 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -64,7 +64,7 @@ fn main() -> AnyhowResult<()> {
     .build()
     .unwrap();
 
-  runtime.block_on(main_2());
+  runtime.block_on(async { main_2().await });
 
 
   Ok(())
@@ -84,17 +84,19 @@ async fn main_2() -> AnyhowResult<()> {
   info!("Configs loaded. Spawning workers...");
 
   let (sender, receiver) = crossbeam::bounded(5);
-  spawn_workers(config.clone(), receiver, 5).await;
+  spawn_workers(config.clone(), receiver, 2).await;
 
   info!("Streaming tweets...");
 
-  thread::sleep(Duration::from_secs(10));
+  //thread::sleep(Duration::from_secs(10));
 
   let stream = egg_mode::stream::filter()
     .track(&["vocodesbot"])
     .language(&["en"])
     .start(&config.token)
     .try_for_each(|m| {
+      info!("WITHIN THE STREAM.");
+
       if let StreamMessage::Tweet(tweet) = m {
         common::print_tweet(&tweet);
         println!("──────────────────────────────────────");
@@ -118,6 +120,7 @@ async fn main_2() -> AnyhowResult<()> {
       futures::future::ok(())
     });
 
+  info!("About to await...");
 
   if let Err(e) = stream.await {
     let e : egg_mode::error::Error = e;
@@ -145,6 +148,8 @@ async fn main_2() -> AnyhowResult<()> {
     error!("Disconnected")
   }
 
+  info!("Awaited!");
+
   Ok(())
 }