$ show Cysharp/MessagePipe
MessagePipe is a high-performance C# library for in-process and distributed messaging, implementing pub/sub, mediator/CQRS, and request/response patterns with a flexible filter pipeline. It supports both synchronous and asynchronous operations, keyed and keyless subscriptions, and buffered/observable adapters. The library is DI-container agnostic, with first-class integrations for Microsoft.Extensions.DependencyInjection, Unity (Zenject, VContainer), and a built-in lightweight container. Distributed transports include TCP, UDP, Named Pipes, Unix Domain Sockets, Redis, and NATS, with MessagePack binary serialization. A Roslyn analyzer (MPA001) detects forgotten subscription disposal. The codebase is well-structured and performance-optimized (lock-free data structures, pooling, custom awaiters), but suffers from significant code duplication between .NET and Unity variants and embeds large third-party libraries (Zenject, MessagePack) directly in the Unity project, increasing maintenance burden.
The LLM identified 3 files worth highlighting for reuse:
A thread-safe, lock-free list implementation using an array and a free-index stack (implemented with Interlocked operations). Supports O(1) add and remove, dynamic growth, and Trim to shrink. Used internally as the substrate for handler storage in message brokers, but is a self-contained utility applicable to any scenario requiring concurrent collection with efficient removal.
A composite disposable utility that aggregates multiple IDisposable instances into a single disposal unit. Includes a builder pattern (DisposableBagBuilder), support for single-assignment disposable, and integration with CancellationToken. Highly reusable for any .NET project needing structured disposal of resources.
Defines the abstract filter classes (MessageHandlerFilter<T>, AsyncMessageHandlerFilter<T>, RequestHandlerFilter, AsyncRequestHandlerFilter) that form a middleware pipeline around message handling. Filters can be applied globally, per-handler type, or per-subscription, and are ordered by a configurable Order property. The pattern is isolated and reusable for any system requiring composable pre/post invocation logic.