-
Implement
.shutdown(immediate=False)
for both sync and async APIs #720The change is not fully backward compatible:
-
If the queue is closed,
janus.AsyncQueueShutDown
and
janus.SyncQueueShutDown
exceptions are raised instead ofRuntimeError
. -
Both sync and async
.task_done()
and.join()
don't raise any exception
on queue shutdown/closing anymore; it is compatible with shutdown behavior
of stdlib sync and async queues.
-