pool: removed unnecessary timeout during the shutdown notification pr…

…ocess

Signed-off-by: Yuki Kishimoto <[email protected]>

CHANGELOG.md

@@ -53,6 +53,7 @@
 * pool: rework relay connection methods and auto-connection logic ([Yuki Kishimoto])
 * pool: increase `MAX_ADJ_RETRY_SEC` to 120 secs ([Yuki Kishimoto])
 * pool: return reference instead of cloned structs for some getter methods of `Relay` ([Yuki Kishimoto])
+* pool: removed unnecessary timeout during the shutdown notification process ([Yuki Kishimoto])
 * sdk: deprecate `Client::get_events_of` and `Client::get_events_from` methods ([Yuki Kishimoto])
 * sdk: use `Events` instead of `Vec<Event>` in fetch and query methods ([Yuki Kishimoto])
 * sdk: rename `stream_events_of` to `stream_events` ([Yuki Kishimoto])

crates/nostr-relay-pool/src/pool/inner.rs

@@ -9,7 +9,7 @@ use std::sync::Arc;
 use std::time::Duration;
 
 use async_utility::futures_util::{future, StreamExt};
-use async_utility::{thread, time};
+use async_utility::thread;
 use atomic_destructor::AtomicDestroyer;
 use nostr::prelude::*;
 use nostr_database::{DynNostrDatabase, Events, IntoNostrDatabase};
@@ -71,12 +71,9 @@ impl InnerRelayPool {
         self.disconnect().await?;
 
         // Send shutdown notification
-        time::timeout(Some(Duration::from_secs(1)), async move {
-            let _ = self
-                .notification_sender
-                .send(RelayPoolNotification::Shutdown);
-        })
-        .await;
+        let _ = self
+            .notification_sender
+            .send(RelayPoolNotification::Shutdown);
 
         tracing::info!("Relay pool shutdown");