3 writes to _reorderingBuffer
System.Threading.Tasks.Dataflow (3)
Blocks\TransformManyBlock.cs (2)
71Initialize(messageWithId => ProcessMessage(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.None); 95Initialize(messageWithId => ProcessMessageWithTask(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.UsesAsyncCompletion);
Blocks\TransformManyBlock.IAsyncEnumerable.cs (1)
45}, dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.UsesAsyncCompletion);
15 references to _reorderingBuffer
System.Threading.Tasks.Dataflow (15)
Blocks\TransformManyBlock.cs (9)
132target = new TargetCore<TInput>(this, processMessageAction, _reorderingBuffer, dataflowBlockOptions, targetCoreOptions); 218if (_reorderingBuffer != null) 314if (_reorderingBuffer != null) 350Debug.Assert(_reorderingBuffer != null, "Expected a reordering buffer"); 360_reorderingBuffer.AddItem(id, null, false); 378bool? isNextNullable = _reorderingBuffer.AddItemIfNextAndTrusted(id, itemAsTrustedList, itemAsTrustedList != null); 427_reorderingBuffer.AddItem(id, itemCopy, itemIsValid: itemCopy != null); 438Debug.Assert(_reorderingBuffer == null, "Expected not to have a reordering buffer"); 469_reorderingBuffer != null;
Blocks\TransformManyBlock.IAsyncEnumerable.cs (6)
96if (_reorderingBuffer is not null) 122Debug.Assert(_reorderingBuffer is not null, "Expected a reordering buffer"); 132_reorderingBuffer.AddItem(id, null, false); 147if (_reorderingBuffer.IsNext(id)) 187_reorderingBuffer.AddItem(id, itemCopy, itemIsValid: itemCopy is not null); 205_reorderingBuffer is not null;