add websocket client test
This commit is contained in:
@@ -84,7 +84,7 @@ class ApiListener(Node):
|
|||||||
async def handle_api(self):
|
async def handle_api(self):
|
||||||
self.get_logger().info('Starting API')
|
self.get_logger().info('Starting API')
|
||||||
self.server = await websockets.serve(self.api_handler, '0.0.0.0', 9001)
|
self.server = await websockets.serve(self.api_handler, '0.0.0.0', 9001)
|
||||||
self.get_logger().info('API started')
|
self.get_logger().info('API started on port 9001')
|
||||||
await self.server.wait_closed()
|
await self.server.wait_closed()
|
||||||
|
|
||||||
def process_image_request(self, message_json):
|
def process_image_request(self, message_json):
|
||||||
|
|||||||
12
websocket-client-test.py
Normal file
12
websocket-client-test.py
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
import asyncio
|
||||||
|
from websockets.sync.client import connect
|
||||||
|
|
||||||
|
def hello():
|
||||||
|
with connect("ws://localhost:8765") as websocket:
|
||||||
|
websocket.send("Hello world!")
|
||||||
|
message = websocket.recv()
|
||||||
|
print(f"Received: {message}")
|
||||||
|
|
||||||
|
hello()
|
||||||
Reference in New Issue
Block a user