Async WebSocket Pool
This repository contains a Python-based asynchronous WebSocket pool that allows for asynchronous connections to multiple WebSocket endpoints.
Getting Started
These instructions will get you a copy of the project up and running on your local machine.
Installation
You can install the async-websocket-pool
using pip:
pip install async-websocket-pool
Please note that this project requires Python 3.7 or later.
Usage
from async_websocket_pool import connect, run_pool
async def on_message(message):
print(message)
tasks = [
lambda: connect('ws://example1.com', on_message=on_message, timeout=5),
lambda: connect('ws://example2.com', on_message=on_message, timeout=5),
]
await run_pool(tasks)
Built With
- Poetry - Packaging and dependency management
Documentation
For more information, please refer to the full documentation.
Contribution
Contributions are always welcome! Please read our contributing guide to learn about our development process, how to propose bugfixes and improvements, and how to build and test your changes.
Authors
mpol1t
License
This project is licensed under the MIT License