collect_queue_messages¶
- lsst.ts.m2com.collect_queue_messages(queue: Queue, name: str, flush: bool = True) list¶
Collect the specific messages in queue.
This function is used in the unit test only.
Parameters¶
- queue
asyncio.Queue Queue of message.
- name
str Name of message.
- flush
bool, optional Flush the queue or not. (the default is True)
Returns¶
- messages
list Messages.
- queue