Function main

python/examples/blocking/ws.py:26–58

()

def main():
    client = BlockingClient()
    with client.websocket("wss://echo.websocket.org") as ws:
        print("Status Code: ", ws.status)
        print("Version: ", ws.version)
        print("Headers: ", ws.headers)
        print("Remote Address: ", ws.remote_addr)

        if ws.ok:
            stop_event = threading.Event()
            send_task = threading.Thread(target=send_message, args=(ws, stop_event))
            receive_task = threading.Thread(
                target=receive_message, args=(ws, stop_event)
            )

            send_task.start()
            receive_task.start()

            def close_ws():
                stop_event.set()
                ws.close()
                send_task.join()
                receive_task.join()

            def signal_handler(sig, frame):
                close_ws()
                exit(0)

            signal.signal(signal.SIGINT, signal_handler)
            signal.signal(signal.SIGTERM, signal_handler)

            send_task.join()
            receive_task.join()


if __name__ == "__main__":