flowmachine.core.server.utils¶
send_zmq_message_and_await_reply¶
send_zmq_message_and_await_reply(msg, port=5555, host="localhost")
Helper function to send JSON messages to the flowmachine server (via zmq) and await a reply. This is mainly useful for interactive testing and debugging asyncio behaviour.
Parameters¶
-
msg
:dict
Dictionary representing a valid zmq message.
-
port
:str
,int
Port on which the flowmachine server is running (default: 5555)
-
host
:str
The host on which the flowmachine server is running (default: 'localhost')
send_zmq_message_and_receive_reply¶
send_zmq_message_and_receive_reply(msg, port=5555, host="localhost")
Helper function to send JSON messages to the flowmachine server (via zmq) and receive a reply. This is mainly useful for interactive testing and debugging.
Parameters¶
-
msg
:dict
Dictionary representing a valid zmq message.
-
port
:str
,int
Port on which the flowmachine server is running (default: 5555)
-
host
:str
The host on which the flowmachine server is running (default: 'localhost')