Release v0.1.2

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Version history
 
+## 0.1.2
+
+- Block socket startup if no thread is available.
+
 ## 0.1.1
 
 - Add `CHANGELOG.md`.

README.md

@@ -2,4 +2,4 @@
 
 # zmq-anyio
 
-Asynchronous API for ZMQ using AnyIO
+Asynchronous API for ZMQ using AnyIO.

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "zmq-anyio"
-version = "0.1.1"
+version = "0.1.2"
 description = "Asynchronous API for ZMQ using AnyIO"
 readme = "README.md"
 authors = [

src/zmq_anyio/_socket.py

@@ -169,7 +169,7 @@ class Socket(zmq.Socket):
     _select_socket_r = None
     _select_socket_w = None
     _stopped = None
-    _started = None
+    started = None
 
     def __init__(
         self,
@@ -197,7 +197,7 @@ def __init__(
         self._select_socket_r, self._select_socket_w = socketpair()
         self._select_socket_r.setblocking(False)
         self._select_socket_w.setblocking(False)
-        self._started = Event()
+        self.started = Event()
         self._stopped = threading.Event()
 
     def close(self, linger: int | None = None) -> None:
@@ -694,13 +694,13 @@ async def __aexit__(self, exc_type, exc_value, exc_tb):
 
     async def start(self, *, task_status: TaskStatus[None] = TASK_STATUS_IGNORED) -> None:
         assert self._task_group is not None
-        assert self._started is not None
+        assert self.started is not None
         self._task_group.start_soon(partial(to_thread.run_sync, self._reader, abandon_on_cancel=True))
-        await self._started.wait()
+        await self.started.wait()
         task_status.started()
 
     def _reader(self):
-        from_thread.run_sync(self._started.set)
+        from_thread.run_sync(self.started.set)
         while True:
             try:
                 rs, ws, xs = select.select([self._shadow_sock, self._select_socket_r.fileno()], [], [self._shadow_sock, self._select_socket_r.fileno()])