MuxPyx

MuxPyx is a Python library that provides multiplexing primitives for asynchronous I/O, allowing multiple logical data streams to share a single transport channel. It targets Python's asynchronous programming model and can operate over TCP, Unix sockets, or in-process channels. The library emphasizes low-latency communication, backpressure-aware framing, and protocol-agnostic message delivery. It targets Python's asynchronous programming model and can operate over TCP, Unix sockets, or in-process channels. The library emphasizes low-latency communication, backpressure-aware framing, and protocol-agnostic message delivery.

The core concept is the multiplexed connection, which hosts multiple Channel objects. Each channel carries framed messages with lightweight metadata, enabling efficient demultiplexing at the receiving end. The framing protocol supports message boundaries, flow control, and error signaling. Transports are implemented as plug-ins, enabling usage with asyncio-based transports, as well as alternative event loops via adapters.

MuxPyx consists of a core engine, a transport layer, and a protocol layer. The core manages channel lifecycle, sequencing of frames, and backpressure. The protocol layer defines how frames are serialized and how control messages such as channel creation, closure, and reset are handled. Transports provide I/O semantics and noise handling. The project emphasizes deterministic scheduling and clear separation between data and control planes.

Usage: developers create a multiplexed connection, open channels as needed, and send messages to remote endpoints. A typical pattern involves event-driven callbacks or awaiting asynchronous reads to process incoming frames per channel. The API emphasizes composability through small, well-documented primitives.

Licensing and development: muxPyx is distributed under an open-source license and maintained with public issue tracking, documentation, and unit tests. The project invites contributions and provides a standard set of integration tests and examples.

See also: asyncio, message framing, multiplexing, Python I/O libraries.