1 write to _reorderingBuffer
System.Threading.Tasks.Dataflow (1)
Blocks\TransformBlock.cs (1)
120_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)
128_reorderingBuffer, dataflowBlockOptions, TargetCoreOptions.None); 135_reorderingBuffer, dataflowBlockOptions, TargetCoreOptions.UsesAsyncCompletion); 202if (_reorderingBuffer == null) 219else _reorderingBuffer.AddItem(messageWithId.Value, outputItem!, itemIsValid); 251_reorderingBuffer?.IgnoreItem(messageWithId.Value); 306if (_reorderingBuffer == null) 326else _reorderingBuffer.AddItem(messageWithId.Value, outputItem!, itemIsValid: gotOutputItem);