chore: add debug print

1c3t3a · Aug 10, 2022 · d709f6c · d709f6c
1 parent 2a47343
commit d709f6c
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/engineio/src/transports/websocket.rs b/engineio/src/transports/websocket.rs
@@ -47,15 +47,23 @@ impl WebsocketTransport {
 impl Transport for WebsocketTransport {
     fn emit(&self, data: Bytes, is_binary_att: bool) -> Result<()> {
         self.runtime.block_on(async {
+            println!("emit will get lock");
             let lock = self.inner.lock().await;
-            lock.emit(data, is_binary_att).await
+            println!("emit did get lock");
+            let r = lock.emit(data, is_binary_att).await;
+            println!("emit free lock");
+            r
         })
     }
 
     fn poll(&self) -> Result<Bytes> {
         self.runtime.block_on(async {
+            println!("wait lock");
             let mut lock = self.inner.lock().await;
-            lock.next().await.ok_or(Error::IncompletePacket())?
+            println!("got lock");
+            let r = lock.next().await.ok_or(Error::IncompletePacket())?;
+            println!("free lock");
+            r
         })
     }