mirror of
				https://github.com/KevinMidboe/delugeClient.git
				synced 2025-10-29 12:00:13 +00:00 
			
		
		
		
	Added example usage for deluge_socket connection.
This commit is contained in:
		
							
								
								
									
										27
									
								
								deluge_socket.py
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										27
									
								
								deluge_socket.py
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,27 @@ | ||||
| import asyncio | ||||
| import datetime | ||||
| import random | ||||
| import websockets | ||||
|  | ||||
| async def hello(websocket, path): | ||||
| 	name = await websocket.recv() | ||||
| 	print(f"< {name}") | ||||
|  | ||||
| 	greeting = f"Hello {name}!" | ||||
|  | ||||
| 	await websocket.send(greeting) | ||||
| 	print(f"> {greeting}") | ||||
|  | ||||
| # start_server = websocket.serve(hello, 'localhost', 8765) | ||||
|  | ||||
| async def time(websocket, path): | ||||
| 	while True: | ||||
| 		now = datetime.datetime.utcnow().isoformat() + 'Z' | ||||
| 		await websocket.send(now) | ||||
| 		# await asyncio.sleep(random.random() * 3) | ||||
| 		await asyncio.sleep(1) | ||||
|  | ||||
| start_server = websockets.serve(time, 'localhost', 5678) | ||||
|  | ||||
| asyncio.get_event_loop().run_until_complete(start_server) | ||||
| asyncio.get_event_loop().run_forever() | ||||
		Reference in New Issue
	
	Block a user