Metadata-Version: 2.1
Name: parallel_websocket_server
Version: 0.1.0
Summary: python multiprocessing websocket server
Home-page: https://github.com/2ndr9/parallel_websocket_server
Author: 2ndr9
Requires-Python: >=3.9,<4.0
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Requires-Dist: websockets (>=11.0.3,<12.0.0)
Project-URL: Repository, https://github.com/2ndr9/parallel_websocket_server
Description-Content-Type: text/markdown

# parallel_websocket_server

run websocket server in parallel (using multiprocessing)

## Installation

```bash
pip install parallel_websocket_server
```

## How to use

```python

import json
import random
from parallel_websocket_server import ParallelWebSocketServer


if __name__ == "__main__":
    receive_queue = mp.Queue()
    send_queue = mp.Queue()

    server = ParallelWebSocketServer(receive_queue, send_queue)

    while True:
        if not receive_queue.empty():
            received_message = receive_queue.get_nowait()
            print(received_message)

        ran = random.random()
        if ran < 0.00001:
            send_queue.put(json.dumps({"hoge": 1}))

```

