6 references to _reorderingBuffer
System.Threading.Tasks.Dataflow (6)
Internal\ReorderingBuffer.cs (6)
51
private object ValueLock { get { return
_reorderingBuffer
; } }
87
_reorderingBuffer
.Add(id, new KeyValuePair<bool, TOutput>(itemIsValid, item!));
167
while (
_reorderingBuffer
.TryGetValue(_nextReorderedIdToOutput, out nextOutputItemWithValidity))
169
_reorderingBuffer
.Remove(_nextReorderedIdToOutput);
176
private int CountForDebugging { get { return
_reorderingBuffer
.Count; } }
193
public Dictionary<long, KeyValuePair<bool, TOutput>> ItemsBuffered { get { return _buffer.
_reorderingBuffer
; } }