13 references to BufferBlock
System.Threading.Tasks.Dataflow (13)
Blocks\BufferBlock.cs (13)
24[DebuggerTypeProxy(typeof(BufferBlock<>.DebugView))] 38/// <summary>Initializes the <see cref="BufferBlock{T}"/>.</summary> 43/// <summary>Initializes the <see cref="BufferBlock{T}"/> with the specified <see cref="DataflowBlockOptions"/>.</summary> 44/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="BufferBlock{T}"/>.</param> 60onItemsRemoved = static (owningSource, count) => ((BufferBlock<T>)owningSource).OnItemsRemoved(count); 66static owningSource => ((BufferBlock<T>)owningSource).Complete(), 75var thisBlock = ((BufferBlock<T>)state!) as IDataflowBlock; 82dataflowBlockOptions.CancellationToken, _source.Completion, static (owningSource, _) => ((BufferBlock<T>)owningSource!).Complete(), this); 261new Task(static state => ((BufferBlock<T>)state!).ConsumeMessagesLoopCore(), this, 393var thisBufferBlock = (BufferBlock<T>)state!; 440private readonly BufferBlock<T> _bufferBlock; 446public DebugView(BufferBlock<T> bufferBlock)