Module streaming_multiplexer 

Zero-copy streaming multiplexer for request deduplication.

This module provides a streaming multiplexer that detects duplicate requests and broadcasts their responses to multiple subscribers without copying data. This enables 10-100x throughput improvements when handling multiple identical requests.

The multiplexer uses:

• tokio::sync::broadcast for lock-free multi-subscriber channels
• Request hashing for O(1) duplicate detection
• Arc-based zero-copy data sharing

Structs

MultiplexedStream

A stream that receives multiplexed data from a broadcast channel

MultiplexerStats

Statistics about the multiplexer state

StreamingMultiplexer

Zero-copy streaming multiplexer for request deduplication