tokio-stream-multiplexor

Stream Multiplexor for tokio with a tcp like interface

15 releases (4 breaking)

0.5.6 Nov 26, 2021
0.5.5 Nov 26, 2021
0.4.3 Nov 26, 2021
0.3.1 Nov 23, 2021
0.1.0 Nov 21, 2021

#861 in Asynchronous

MIT license

52KB
1.5K SLoC

Build Status Rust Crates.io Crates.io docs.rs

Tokio Stream Multiplexor

TL;DR: Multiplex multiple streams over a single stream. Has a TcpListener / TcpSocket style interface, and uses u16 ports similar to TCP itself.

[dependencies]
foo = "1.2.3"

Why?

Because sometimes you wanna cram as much shite down one TCP stream as you possibly can, rather than have your application connect with multiple ports.

But Whyyyyyy?

Because I needed it. Inspired by async-smux, written for Tokio.

What about performance?

Doesn't this whole protocol in a protocol thing hurt perf?

Sure, but take a look at the benches:

throughput/tcp          time:   [28.968 ms 30.460 ms 31.744 ms]
                        thrpt:  [7.8755 GiB/s 8.2076 GiB/s 8.6303 GiB/s]

throughput/mux          time:   [122.24 ms 135.96 ms 158.80 ms]
                        thrpt:  [1.5743 GiB/s 1.8388 GiB/s 2.0451 GiB/s]

Approximately 4.5 times slower than TCP, but still able to shovel 1.8 GiB/s of shite... Seems alright to me. (Numbers could possibly be improved with some tuning of the config params too.)

Dependencies

~5–14MB
~159K SLoC