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)
127
reorderingBuffer = new
ReorderingBuffer
<IEnumerable<TOutput>>(
6 references to ReorderingBuffer
System.Threading.Tasks.Dataflow (6)
Blocks\TransformBlock.cs (1)
30
private readonly
ReorderingBuffer
<TOutput>? _reorderingBuffer;
Blocks\TransformManyBlock.cs (2)
35
private readonly
ReorderingBuffer
<IEnumerable<TOutput>>? _reorderingBuffer;
103
ref
ReorderingBuffer
<IEnumerable<TOutput>>? reorderingBuffer,
Internal\ReorderingBuffer.cs (3)
37
[DebuggerTypeProxy(typeof(
ReorderingBuffer
<>.DebugView))]
182
private readonly
ReorderingBuffer
<TOutput> _buffer;
186
public DebugView(
ReorderingBuffer
<TOutput> buffer)