Clear all messages from the queue.
(self)
| 121 | return items |
| 122 | |
| 123 | def clear(self): |
| 124 | """Clear all messages from the queue.""" |
| 125 | with self.buffer.mutex: |
| 126 | # Empty the queue |
| 127 | self.buffer.queue.clear() |
| 128 | |
| 129 | async def message_generator(self, style: Literal["obj", "api"] = "obj"): |
| 130 | while True: |
no outgoing calls
no test coverage detected