Asyncio TCP Multiplexer
Project description
async_multiplexer
async_multiplexer is a TCP Multiplexer based on Mplex protocol, but simplified. It is intended for creating mutiple streams in parallel on top of a same TCP connection.
Installation
pip install async_multiplexer
Usage
Client
import asyncio
from async_multiplexer import open_multiplexer_context
async def echo_client():
async with open_multiplexer_context("127.0.0.1", 7777) as multiplexer:
stream_echo_1 = await multiplexer.multiplex("echo.1")
stream_echo_2 = await multiplexer.multiplex("echo.2")
await stream_echo_1.write(b"echo.1")
await stream_echo_2.write(b"echo.2")
if __name__ == "__main__":
asyncio.run(echo_client())
Server
import asyncio
from async_multiplexer import bind_multiplex_listener_context
async def handler(stream):
data = await stream.read()
print(data)
async def echo_server():
async with bind_multiplex_listener_context("127.0.0.1", 7777) as listener:
listener.set_handler("echo.1", handler)
listener.set_handler("echo.2", handler)
await asyncio.sleep(10)
if __name__ == "__main__":
asyncio.run(echo_server())
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for async_multiplexer-0.0.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 9fa6428cd410698483f7fd7bab02304c9d657f4afd90c96bc3835a1900738ff0 |
|
MD5 | 11c9167106e7f7546bfe9c95fb5012a0 |
|
BLAKE2b-256 | 6a4242135e0a1c793ffa41416cedaa1b4f247976ccfcd014571f43551231ceae |