collect_queue_messages

lsst.ts.m2com.collect_queue_messages(queue, name, flush=True)

Collect the specific messages in queue.

This function is used in the unit test only.

Parameters:

queueasyncio.Queue

Queue of message.

namestr

Name of message.

flushbool, optional

Flush the queue or not. (the default is True)

Returns:

messageslist

Messages.