bluesky_queueserver.ReceiveConsoleOutputAsync.recv

async ReceiveConsoleOutputAsync.recv(timeout=-1)[source]

Get the next published message. If timeout expires then TimeoutError is raised. If the socket is not subscribed to to topic, then subscribes the socket.

Parameters:
timeoutint, float or None

Timeout for the receive operation in milliseconds. If timeout is a negative number (default), the timeout value passed to the class constructor is used. If None, then wait indefinitely.

Returns:
dict

Received message. The dictionary contains timestamp (time key) and text message (msg key).

Raises:
TimeoutError

Timeout occurred. Timeout does not indicate communication error.