namespace FreiLabs.Core.Engine { public sealed class HighThroughputPipeline<TMessage> : IAsyncDisposable { private readonly Channel<TMessage> _channel = Channel.CreateBounded<TMessage>(new BoundedChannelOptions(10_000) { FullMode = BoundedChannelFullMode.Wait, SingleReader = true, SingleWriter = false }); [MethodImpl(MethodImplOptions.AggressiveInlining)] public async ValueTask PublishAsync(ReadOnlyMemory<byte> payload, CancellationToken ct = default) { var span = payload.Span; if (MemoryMarshal.TryGetArray(payload, out var segment)) { await _channel.Writer.WriteAsync(ParseRecord(segment.Array), ct); } } } }