pool: fix send_event_to incorrect timeout error

immedately listen for OK msgs when events are sent using batch_events.

prevents the OK msg from being missed, causing the to
eventually fail through timeout when the msg was successfully recieved by relays.

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

@@ -12,6 +12,7 @@ use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
 use std::time::Duration;
 
+use async_utility::futures_util::future::{join, join_all};
 #[cfg(not(target_arch = "wasm32"))]
 use async_utility::futures_util::stream::AbortHandle;
 use async_utility::{futures_util, thread, time};
@@ -1063,10 +1064,10 @@ impl InternalRelay {
         }
 
         // Batch send messages
-        self.batch_msg(msgs, opts).await?;
+        let send_batch_msg = self.batch_msg(msgs, opts);
 
         // Hanlde responses
-        time::timeout(Some(opts.timeout), async {
+        let handle_responses = time::timeout(Some(opts.timeout), async {
             let mut published: HashSet<EventId> = HashSet::new();
             let mut not_published: HashMap<EventId, String> = HashMap::new();
             let mut notifications = self.internal_notification_sender.subscribe();
@@ -1121,9 +1122,13 @@ impl InternalRelay {
             } else {
                 Err(Error::EventsNotPublished(not_published))
             }
-        })
-        .await
-        .ok_or(Error::Timeout)?
+        });
+
+        let (send_batch_msg_res, handle_responses_res) =
+            join(send_batch_msg, handle_responses).await;
+
+        send_batch_msg_res?;
+        handle_responses_res.ok_or(Error::Timeout)?
     }
 
     async fn resubscribe_all(&self, opts: RelaySendOptions) -> Result<(), Error> {