1 write to _source
System.Threading.Tasks.Dataflow (1)
Blocks\BufferBlock.cs (1)
62_source = new SourceCore<T>(this, dataflowBlockOptions,
23 references to _source
System.Threading.Tasks.Dataflow (23)
Blocks\BufferBlock.cs (23)
36private object IncomingLock { get { return _source; } } 70_source.Completion.ContinueWith(static (completed, state) => 79dataflowBlockOptions.CancellationToken, _source.Completion, static (owningSource, _) => ((BufferBlock<T>)owningSource!).Complete(), this); 124_source.AddMessage(messageValue!); 165_source.AddException(exception); 183public IDisposable LinkTo(ITargetBlock<T> target, DataflowLinkOptions linkOptions) { return _source.LinkTo(target, linkOptions); } 186public bool TryReceive(Predicate<T>? filter, [MaybeNullWhen(false)] out T item) { return _source.TryReceive(filter, out item); } 189public bool TryReceiveAll([NotNullWhen(true)] out IList<T>? items) { return _source.TryReceiveAll(out items); } 192public int Count { get { return _source.OutputCount; } } 195public Task Completion { get { return _source.Completion; } } 200return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 206return _source.ReserveMessage(messageHeader, target); 212_source.ReleaseReservation(messageHeader, target); 267Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 289int maxMessagesPerTask = _source.DataflowBlockOptions.ActualMaxMessagesPerTask; 356_source.AddMessage(consumedValue!); 403thisBufferBlock._source.AddExceptions(exceptions); 406thisBufferBlock._source.Complete(); 412_source.Complete(); 418private int CountForDebugger { get { return _source.GetDebuggingInformation().OutputCount; } } 421public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 425$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, Count = {CountForDebugger}"; 444_sourceDebuggingInformation = bufferBlock._source.GetDebuggingInformation();