2 references to 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)
127
reorderingBuffer = new
ReorderingBuffer
<IEnumerable<TOutput>>(