diff --git a/README.rst b/README.rst index 1051d42..cb8953f 100644 --- a/README.rst +++ b/README.rst @@ -69,8 +69,7 @@ Example fut = loop.run_in_executor(None, threaded, queue.sync_q) await async_coro(queue.async_q) await fut - queue.close() - await queue.wait_closed() + await queue.aclose() asyncio.run(main()) @@ -83,8 +82,8 @@ This library is built using a classic thread-safe design. The design is time-tested, but has some limitations. * Once you are done working with a queue, you must properly close it using - ``close()`` and ``wait_closed()``. This is because this library creates new - tasks to notify other threads. If you do not properly close the queue, + ``aclose()``. This is because this library creates new tasks to notify other + threads. If you do not properly close the queue, `asyncio may generate error messages `_. * The library has acceptable performance only when used as intended, that is, @@ -92,7 +91,7 @@ time-tested, but has some limitations. For sync-only and async-only cases, use queues from `queue `_ and `asyncio `_ modules, - otherwise `the slowdown will be significant + otherwise `the slowdown can be significant `_. * You cannot use queues for communicating between two different event loops because, like all asyncio primitives, they bind to the current one.