nats_multi_request_py

Python function to return one or multiple responses to a NATS request as soon as possible.

Installation

pip install https://github.com/edf-re/nats_multi_request_py.git

Usage

One response

Return a single NATS Msg.

>>> import nats_multi_request
>>> nats_multi_request.req_asap(z, b'{"nodes": ["af9c"]}', timeout=5)
<Msg: subject='_INBOX.tdSY0nNLoa9bYPqw9moCwC' reply='' data='{"initial_...'>

Multiple responses

Return a list of NATS Msgs.

>>> nats_multi_request.req_asap(z, b'{"nodes": "all"}', expected=3, timeout=5)
[<Msg: subject='_INBOX.tdSY0nNLoa9bmNqw9moCwC' reply='' data='{"error": ...'>,
 <Msg: subject='_INBOX.tdSY0nNLoa9bmNqw9moCwC' reply='' data='{"initial_...'>,
 <Msg: subject='_INBOX.tdSY0nNLoa9bmNqw9moCwC' reply='' data='{"initial_...'>]

License

This project is under the MIT License. See LICENSE.txt.