update dependencies

Author: gottadiveintopython

poetry.lock

@@ -25,7 +25,7 @@ packages = [
 
 [tool.poetry.dependencies]
 python = "^3.10"
-asyncgui = "^0.6"
+asyncgui = "~0.7"
 
 [tool.poetry.group.dev.dependencies]
 pytest = "^8.0"

pyproject.toml

@@ -74,7 +74,7 @@ async def async_fn2(q, consumed):
 from functools import partial
 from collections import deque
 
-from asyncgui import AsyncEvent
+from asyncgui import ExclusiveEvent
 
 
 class QueueState(enum.Enum):
@@ -138,8 +138,8 @@ def __init__(self, *, capacity: int | None=None, order: Order='fifo'):
             raise ValueError(f"'capacity' must be either a positive integer or None. (was {capacity!r})")
         self._init_container(capacity, order)
         self._state = QueueState.OPENED
-        self._putters = deque[tuple[AsyncEvent, Item]]()
-        self._getters = deque[AsyncEvent]()
+        self._putters = deque[tuple[ExclusiveEvent, Item]]()
+        self._getters = deque[ExclusiveEvent]()
         self._capacity = capacity
         self._order = order
         self._is_transferring = False
@@ -200,7 +200,7 @@ async def get(self) -> T.Awaitable[Item]:
             raise Closed
 
         if self._is_transferring or self.is_empty:
-            event = AsyncEvent()
+            event = ExclusiveEvent()
             self._getters.append(event)
             exc, item = (await event.wait())[0]
             if exc is not None:
@@ -240,7 +240,7 @@ async def put(self, item) -> T.Awaitable:
             raise Closed
 
         if self._is_transferring or self.is_full:
-            event = AsyncEvent()
+            event = ExclusiveEvent()
             self._putters.append((event, item, ))
             exc = (await event.wait())[0][0]
             if exc is not None: