feat(adapter): remove adapter generic param and use boxed

Totodore · May 24, 2024 · 919ca81 · 919ca81
1 parent d5c01f7
commit 919ca81
Show file tree

Hide file tree

Showing 20 changed files with 473 additions and 472 deletions.
diff --git a/socketioxide/src/ack.rs b/socketioxide/src/ack.rs
@@ -145,9 +145,9 @@ impl AckInnerStream {
     ///
     /// The [`AckInnerStream`] will wait for the default timeout specified in the config
     /// (5s by default) if no custom timeout is specified.
-    pub fn broadcast<A: Adapter>(
+    pub fn broadcast(
         packet: Packet<'static>,
-        sockets: Vec<SocketRef<A>>,
+        sockets: Vec<SocketRef>,
         duration: Option<Duration>,
     ) -> Self {
         let rxs = FuturesUnordered::new();
@@ -311,13 +311,13 @@ mod test {
     use engineioxide::sid::Sid;
     use futures_util::StreamExt;
 
-    use crate::{adapter::LocalAdapter, ns::Namespace, socket::Socket};
+    use crate::{ns::Namespace, socket::Socket};
 
     use super::*;
 
-    fn create_socket() -> Arc<Socket<LocalAdapter>> {
+    fn create_socket() -> Arc<Socket> {
         let sid = Sid::new();
-        let ns = Namespace::<LocalAdapter>::new_dummy([sid]).into();
+        let ns = Namespace::new_dummy([sid]).into();
         let socket = Socket::new_dummy(sid, ns);
         socket.into()
     }