File tree Expand file tree Collapse file tree 1 file changed +0
-9
lines changed
src/py/reactpy/reactpy/core Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Original file line number Diff line number Diff line change 4
4
from asyncio import (
5
5
FIRST_COMPLETED ,
6
6
CancelledError ,
7
- Event ,
8
7
Queue ,
9
8
Task ,
10
9
create_task ,
@@ -709,23 +708,15 @@ def __init__(self) -> None:
709
708
self ._loop = get_running_loop ()
710
709
self ._queue : Queue [_Type ] = Queue ()
711
710
self ._pending : set [_Type ] = set ()
712
- self ._ready = Event ()
713
711
714
712
def put (self , value : _Type ) -> None :
715
713
if value not in self ._pending :
716
714
self ._pending .add (value )
717
715
self ._loop .call_soon_threadsafe (self ._queue .put_nowait , value )
718
- self ._ready .set ()
719
-
720
- async def ready (self ) -> None :
721
- """Return when the next value is available"""
722
- await self ._ready .wait ()
723
716
724
717
async def get (self ) -> _Type :
725
718
value = await self ._queue .get ()
726
719
self ._pending .remove (value )
727
- if not self ._pending :
728
- self ._ready .clear ()
729
720
return value
730
721
731
722
You can’t perform that action at this time.
0 commit comments