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