refactor: clean up from the debug and dead code

Author: parfeon

examples/presence_state.rs

@@ -8,13 +8,6 @@ struct State {
     flag: bool,
 }
 
-#[allow(dead_code)]
-#[derive(Debug, serde::Serialize)]
-struct State2 {
-    is_doing: String,
-    business: String,
-}
-
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn snafu::Error>> {
     // let publish_key = env::var("SDK_PUB_KEY")?;

examples/subscribe.rs

@@ -21,7 +21,6 @@ struct Message {
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn snafu::Error>> {
-    env_logger::init();
     let publish_key = env::var("SDK_PUB_KEY")?;
     let subscribe_key = env::var("SDK_SUB_KEY")?;
 
@@ -105,17 +104,6 @@ async fn main() -> Result<(), Box<dyn snafu::Error>> {
             .files_stream()
             .for_each(|file| async move { println!("(b) file: {:?}", file) }),
     );
-    // tokio::time::sleep(tokio::time::Duration::from_secs(2)).await;
-    println!("\nWaiting for message");
-    //
-    // println!("\nPublish a message:");
-    //
-    // pubnub
-    //     .publish_message("{\"event\":\"flag_changed\",\"timestamp\":
-    // 1758130367173}")     .channel("my_channel")
-    //     .execute()
-    //     .await?;
-    // println!("\nDone!");
 
     // Sleep for a minute. Now you can send messages to the channels
     // "my_channel" and "other_channel" and see them printed in the console.

src/core/event_engine/effect_dispatcher.rs

@@ -261,28 +261,6 @@ mod should {
         }
     }
 
-    #[allow(dead_code)]
-    #[derive(Clone)]
-    struct TestRuntime {}
-
-    #[async_trait::async_trait]
-    impl Runtime for TestRuntime {
-        fn spawn<R>(&self, _future: impl Future<Output = R> + Send + 'static)
-        where
-            R: Send + 'static,
-        {
-            // Do nothing.
-        }
-
-        async fn sleep(self, _delay: u64) {
-            // Do nothing.
-        }
-
-        async fn sleep_microseconds(self, _delay: u64) {
-            // Do nothing.
-        }
-    }
-
     #[test]
     fn create_not_managed_effect() {
         let (_tx, rx) = async_channel::bounded::<TestInvocation>(5);