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)
- queue
- Returns:
- messages
list Messages.
- messages