1 write to _reorderingBuffer
System.Threading.Tasks.Dataflow (1)
Blocks\TransformBlock.cs (1)
116_reorderingBuffer = new ReorderingBuffer<TOutput>(this, static (owningSource, message) => ((TransformBlock<TInput, TOutput>)owningSource)._source.AddMessage(message));
7 references to _reorderingBuffer
System.Threading.Tasks.Dataflow (7)
Blocks\TransformBlock.cs (7)
124_reorderingBuffer, dataflowBlockOptions, TargetCoreOptions.None); 131_reorderingBuffer, dataflowBlockOptions, TargetCoreOptions.UsesAsyncCompletion); 198if (_reorderingBuffer == null) 215else _reorderingBuffer.AddItem(messageWithId.Value, outputItem!, itemIsValid); 247_reorderingBuffer?.IgnoreItem(messageWithId.Value); 302if (_reorderingBuffer == null) 322else _reorderingBuffer.AddItem(messageWithId.Value, outputItem!, itemIsValid: gotOutputItem);