1 write to _reorderingBuffer
System.Threading.Tasks.Dataflow (1)
Blocks\TransformBlock.cs (1)
117_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)
125_reorderingBuffer, dataflowBlockOptions, TargetCoreOptions.None); 132_reorderingBuffer, dataflowBlockOptions, TargetCoreOptions.UsesAsyncCompletion); 199if (_reorderingBuffer == null) 216else _reorderingBuffer.AddItem(messageWithId.Value, outputItem!, itemIsValid); 248_reorderingBuffer?.IgnoreItem(messageWithId.Value); 303if (_reorderingBuffer == null) 323else _reorderingBuffer.AddItem(messageWithId.Value, outputItem!, itemIsValid: gotOutputItem);