Skip to content

Commit e0fa84a

Browse files
committed
Fix type hints
1 parent 7f97ffe commit e0fa84a

File tree

1 file changed

+4
-8
lines changed

1 file changed

+4
-8
lines changed

janus/__init__.pyi

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,7 @@ class Queue(Generic[_T]):
99

1010
def close(self) -> None: ...
1111

12-
@asyncio.coroutine
13-
def wait_closed(self) -> Generator[Any, None, None]: ...
12+
async def wait_closed(self) -> None: ...
1413

1514
@property
1615
def maxsize(self) -> int: ...
@@ -54,20 +53,17 @@ class _AsyncQueueProxy(Generic[_T]):
5453

5554
def task_done(self) -> None: ...
5655

57-
@asyncio.coroutine
58-
def join(self) -> Generator[Any, None, None]: ...
56+
async def join(self) -> None: ...
5957

6058
def qsize(self) -> int: ...
6159

6260
def empty(self) -> bool: ...
6361

6462
def full(self) -> bool: ...
6563

66-
@asyncio.coroutine
67-
def put(self, item: _T) -> Generator[Any, None, None]: ...
64+
async def put(self, item: _T) -> None: ...
6865

69-
@asyncio.coroutine
70-
def get(self) -> Generator[Any, None, _T]: ...
66+
async def get(self) -> _T: ...
7167

7268

7369
def put_nowait(self, item: _T) -> None: ...

0 commit comments

Comments
 (0)