Optimize zero-timeout Python receives for 3.0.2

Cargo.toml

@@ -3,7 +3,7 @@ members = ["src/rust", "src/c", "src/python", "src/node"]
 resolver = "2"
 
 [workspace.package]
-version = "3.0.1"
+version = "3.0.2"
 edition = "2021"
 license = "MIT"
 repository = "https://github.com/cloudtoid/interprocess"

src/c/CMakeLists.txt

@@ -1,5 +1,5 @@
 cmake_minimum_required(VERSION 3.20)
-project(cloudtoid_interprocess VERSION 3.0.1 LANGUAGES C)
+project(cloudtoid_interprocess VERSION 3.0.2 LANGUAGES C)
 include(GNUInstallDirs)
 find_program(CARGO_EXECUTABLE cargo REQUIRED)
 get_filename_component(REPO_ROOT "${CMAKE_CURRENT_SOURCE_DIR}/../.." ABSOLUTE)

src/c/Cargo.toml

@@ -14,4 +14,4 @@ name = "cloudtoid_interprocess"
 crate-type = ["cdylib", "staticlib"]
 
 [dependencies]
-core-queue = { package = "cloudtoid-interprocess", path = "../rust", version = "3.0.1" }
+core-queue = { package = "cloudtoid-interprocess", path = "../rust", version = "3.0.2" }

src/node/Cargo.toml

@@ -12,7 +12,7 @@ doctest = false
 crate-type = ["cdylib"]
 
 [dependencies]
-core-queue = { package = "cloudtoid-interprocess", path = "../rust", version = "3.0.1" }
+core-queue = { package = "cloudtoid-interprocess", path = "../rust", version = "3.0.2" }
 # Native calls are synchronous; JS handles waiting. No N-API thread-safe
 # callback/GC dispatcher is needed (enabled by napi4 and later).
 napi = { version = "3", default-features = false, features = ["napi3"] }

src/node/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@cloudtoid/interprocess",
-  "version": "3.0.1",
+  "version": "3.0.2",
   "description": "Fast shared-memory byte queues across Node.js, Rust, C, Go, Python, and .NET",
   "main": "index.js",
   "types": "index.d.ts",
@@ -25,11 +25,11 @@
     "test": "node --test test.js"
   },
   "optionalDependencies": {
-    "@cloudtoid/interprocess-darwin-arm64": "3.0.1",
-    "@cloudtoid/interprocess-darwin-x64": "3.0.1",
-    "@cloudtoid/interprocess-linux-x64": "3.0.1",
-    "@cloudtoid/interprocess-win32-x64": "3.0.1",
-    "@cloudtoid/interprocess-linux-arm64": "3.0.1"
+    "@cloudtoid/interprocess-darwin-arm64": "3.0.2",
+    "@cloudtoid/interprocess-darwin-x64": "3.0.2",
+    "@cloudtoid/interprocess-linux-x64": "3.0.2",
+    "@cloudtoid/interprocess-win32-x64": "3.0.2",
+    "@cloudtoid/interprocess-linux-arm64": "3.0.2"
   },
   "exports": {
     ".": {

src/python/Cargo.toml

@@ -14,7 +14,7 @@ name = "_native"
 crate-type = ["cdylib"]
 
 [dependencies]
-core-queue = { package = "cloudtoid-interprocess", path = "../rust", version = "3.0.1" }
+core-queue = { package = "cloudtoid-interprocess", path = "../rust", version = "3.0.2" }
 pyo3 = { version = "0.29", features = ["extension-module", "abi3-py39"] }
 
 [build-dependencies]

src/python/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "maturin"
 
 [project]
 name = "cloudtoid-interprocess"
-version = "3.0.1"
+version = "3.0.2"
 description = "Fast shared-memory byte queues across Python, Rust, C, Go, Node.js, and .NET"
 requires-python = ">=3.9"
 license = "MIT"

src/python/python/cloudtoid_interprocess/__init__.py

@@ -3,4 +3,4 @@
 from ._native import Publisher, Subscriber
 
 __all__ = ["Publisher", "Subscriber", "InterprocessError", "CapacityMismatchError", "PublisherLimitError", "CorruptQueueError"]
-__version__ = "3.0.1"
+__version__ = "3.0.2"

src/python/src/lib.rs

@@ -143,6 +143,14 @@ impl Subscriber {
                     .map_err(|_| PyValueError::new_err("timeout must be finite and nonnegative"))
             })
             .transpose()?;
+        if timeout.is_some_and(|limit| limit.is_zero()) {
+            py.check_signals()?;
+            let message = self.try_receive(py)?;
+            if message.is_none() {
+                py.check_signals()?;
+            }
+            return Ok(message);
+        }
         let started = Instant::now();
         loop {
             py.check_signals()?;

src/python/test_api.py

@@ -19,6 +19,7 @@ def test_api(self):
             self.assertEqual(s.receive(timeout=0), b"a")
             self.assertEqual(s.receive(timeout=1), b"b")
             self.assertIsNone(s.receive(timeout=0.005))
+            self.assertIsNone(s.receive(timeout=0))
             with self.assertRaises(ValueError): s.receive(timeout=-1)
         with self.assertRaises(ValueError): p.try_send(b"closed")
         with self.assertRaises(ValueError): s.try_receive()