Method server_handler

tests/test_dirty_client.py:293–303

()

            response_sent = threading.Event()

            def server_handler():
                conn, _ = server_sock.accept()
                try:
                    # Read request
                    msg = DirtyProtocol.read_message(conn)
                    # Send response
                    resp = make_response(msg["id"], {"result": "success"})
                    DirtyProtocol.write_message(conn, resp)
                    response_sent.set()
                finally:
                    conn.close()

            server_thread = threading.Thread(target=server_handler)
            server_thread.start()