nats_request_asap

async nats_request_asap.request(nats_conn: nats.aio.client.Client, subject: str, payload: bytes, error_if_lt_expected=False, timeout=0.5, expected=1) → Union[nats.aio.client.Msg, List[nats.aio.client.Msg]]

Make a request to NATS. Return response as soon as it arrives. If expected > 1, return multiple responses.

Parameters

• subject – NATS subject

• payload – NATS payload, should be bytes

• error_if_lt_expected – Raise error is less than expected responses received. Converted to boolean

• timeout – Time to wait for expected responses.

• expected – Expected number of messages.

Returns

Msg if expected == 1

Returns

List[Msg] if expected > 1

Raises

nats.aio.errors.ErrTimeout – if no responses received or if error_if_lt_expected is True and less than expected responses received.