Release the queue.
(self)
| 356 | return self.ref_count |
| 357 | |
| 358 | async def release(self) -> int: |
| 359 | """Release the queue.""" |
| 360 | self.ref_count -= 1 |
| 361 | if self.ref_count <= 0: |
| 362 | await self.queue.close() |
| 363 | if self.writer is not None: |
| 364 | await self.writer.release() |
| 365 | return self.ref_count |
| 366 | |
| 367 | def length(self) -> int: |
| 368 | """The length of the queue.""" |