(self, obj: Any)
| 492 | self._send_thread.start() |
| 493 | |
| 494 | def put(self, obj: Any): |
| 495 | self.setup_sender() |
| 496 | if self.fuse_message: |
| 497 | self.sending_queue.put_nowait(obj) |
| 498 | else: |
| 499 | batch = obj if isinstance(obj, list) else [obj] |
| 500 | self.queue.put(batch) |
| 501 | |
| 502 | def get(self) -> Any: |
| 503 | return self.queue.get() |
nothing calls this directly
no test coverage detected