diff --git a/janus/__init__.pyi b/janus/__init__.pyi
index b6c4b3c..3f08f20 100644
--- a/janus/__init__.pyi
+++ b/janus/__init__.pyi
@@ -9,8 +9,7 @@ class Queue(Generic[_T]):
 
     def close(self) -> None: ...
 
-    @asyncio.coroutine
-    def wait_closed(self) -> Generator[Any, None, None]: ...
+    async def wait_closed(self) -> None: ...
 
     @property
     def maxsize(self) -> int: ...
@@ -54,8 +53,7 @@ class _AsyncQueueProxy(Generic[_T]):
 
     def task_done(self) -> None: ...
 
-    @asyncio.coroutine
-    def join(self) -> Generator[Any, None, None]: ...
+    async def join(self) -> None: ...
 
     def qsize(self) -> int: ...
 
@@ -63,11 +61,9 @@ class _AsyncQueueProxy(Generic[_T]):
 
     def full(self) -> bool: ...
 
-    @asyncio.coroutine
-    def put(self, item: _T) -> Generator[Any, None, None]: ...
+    async def put(self, item: _T) -> None: ...
 
-    @asyncio.coroutine
-    def get(self) -> Generator[Any, None, _T]: ...
+    async def get(self) -> _T: ...
 
 
     def put_nowait(self, item: _T) -> None: ...