Skip to content

Remove Box and Event, as they are already in the asyncgui module #3

New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

Merged
merged 2 commits into from
Sep 15, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions poetry.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down
8 changes: 0 additions & 8 deletions sphinx/box.rst

This file was deleted.

8 changes: 0 additions & 8 deletions sphinx/event.rst

This file was deleted.

2 changes: 0 additions & 2 deletions sphinx/index.rst
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,4 @@ Inter-task sychronization and communication.
.. toctree::
:hidden:

box
event
queue
4 changes: 1 addition & 3 deletions src/asyncgui_ext/synctools/all.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,4 @@
__all__ = (
'Event', 'Box', 'Queue',
'Queue',
)
from .event import Event
from .box import Box
from .queue import Queue
74 changes: 0 additions & 74 deletions src/asyncgui_ext/synctools/box.py

This file was deleted.

52 changes: 0 additions & 52 deletions src/asyncgui_ext/synctools/event.py

This file was deleted.

10 changes: 5 additions & 5 deletions src/asyncgui_ext/synctools/queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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:
Expand Down Expand Up @@ -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:
Expand Down
102 changes: 0 additions & 102 deletions tests/test_box.py

This file was deleted.

Loading
Loading