2 instantiations of ReorderingBuffer
System.Threading.Tasks.Dataflow (2)
Blocks\TransformBlock.cs (1)
120_reorderingBuffer = new ReorderingBuffer<TOutput>(this, static (owningSource, message) => ((TransformBlock<TInput, TOutput>)owningSource)._source.AddMessage(message));
Blocks\TransformManyBlock.cs (1)
127reorderingBuffer = new ReorderingBuffer<IEnumerable<TOutput>>(
6 references to ReorderingBuffer
System.Threading.Tasks.Dataflow (6)
Blocks\TransformBlock.cs (1)
30private readonly ReorderingBuffer<TOutput>? _reorderingBuffer;
Blocks\TransformManyBlock.cs (2)
35private readonly ReorderingBuffer<IEnumerable<TOutput>>? _reorderingBuffer; 103ref ReorderingBuffer<IEnumerable<TOutput>>? reorderingBuffer,
Internal\ReorderingBuffer.cs (3)
37[DebuggerTypeProxy(typeof(ReorderingBuffer<>.DebugView))] 182private readonly ReorderingBuffer<TOutput> _buffer; 186public DebugView(ReorderingBuffer<TOutput> buffer)