INNER CODE UNIT · Python

__init__

codedpro/mt5-trade-split-manager · server.py:108

    def __init__(self, cmd: dict):
        self.cmd = cmd
        self.event = threading.Event()
        self.result = None
        self.abandoned = False


# Queue of Envelopes waiting to be handed to the EA on its next poll.
command_queue: "queue.Queue[Envelope]" = queue.Queue()


def _read_json_response(sock: socket.socket) -> dict:
    """Read from the EA until a complete JSON object has arrived."""
    sock.settimeout(REQUEST_TIMEOUT)
    data = b''
    while True:
        try:
            chunk = sock.recv(4096)

View source record →