Sync lockfile with Zenoh e9f3b37 from 2024-10-08

eclipse-zenoh · Oct 8, 2024 · a3f7533 · a3f7533
1 parent 724d7fa
commit a3f7533
Show file tree

Hide file tree

Showing 2 changed files with 51 additions and 42 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/src/handlers.rs b/src/handlers.rs
@@ -280,6 +280,19 @@ fn recv<T: IntoPython, E: IntoPyErr + Send>(
     }
 }
 
+enum DeadlineError<E> {
+    Timeout,
+    Error(E),
+}
+impl<E: fmt::Display> fmt::Display for DeadlineError<E> {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        match self {
+            Self::Error(err) => write!(f, "{err}"),
+            Self::Timeout => unreachable!(),
+        }
+    }
+}
+
 impl<T: IntoRust> Receiver for RustHandler<DefaultHandler, T>
 where
     T::Into: IntoPython,
@@ -295,8 +308,12 @@ where
     fn recv(&self, py: Python) -> PyResult<PyObject> {
         recv(
             py,
-            || self.handler.recv_timeout(CHECK_SIGNALS_INTERVAL),
-            |err| matches!(err, flume::RecvTimeoutError::Timeout),
+            || match self.handler.recv_timeout(CHECK_SIGNALS_INTERVAL) {
+                Ok(Some(x)) => Ok(x),
+                Ok(None) => Err(DeadlineError::Timeout),
+                Err(err) => Err(DeadlineError::Error(err)),
+            },
+            |err| matches!(err, DeadlineError::Timeout),
         )
     }
 }
@@ -316,8 +333,12 @@ where
     fn recv(&self, py: Python) -> PyResult<PyObject> {
         recv(
             py,
-            || self.handler.recv_timeout(CHECK_SIGNALS_INTERVAL),
-            |err| matches!(err, flume::RecvTimeoutError::Timeout),
+            || match self.handler.recv_timeout(CHECK_SIGNALS_INTERVAL) {
+                Ok(Some(x)) => Ok(x),
+                Ok(None) => Err(DeadlineError::Timeout),
+                Err(err) => Err(DeadlineError::Error(err)),
+            },
+            |err| matches!(err, DeadlineError::Timeout),
         )
     }
 }
@@ -335,18 +356,6 @@ where
     }
 
     fn recv(&self, py: Python) -> PyResult<PyObject> {
-        enum DeadlineError<E> {
-            Timeout,
-            Error(E),
-        }
-        impl<E: fmt::Display> fmt::Display for DeadlineError<E> {
-            fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
-                match self {
-                    Self::Error(err) => write!(f, "{err}"),
-                    Self::Timeout => unreachable!(),
-                }
-            }
-        }
         recv(
             py,
             || match self.handler.recv_timeout(CHECK_SIGNALS_INTERVAL) {