flowmachine.core.server.utils¶

send_zmq_message_and_await_reply¶

send_zmq_message_and_await_reply(msg, port=5555, host="localhost")

Source: flowmachine/core/server/utils.py

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")

Source: flowmachine/core/server/utils.py

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')