1 write to _source
System.Threading.Tasks.Dataflow (1)
Blocks\BufferBlock.cs (1)
65_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; } } 73_source.Completion.ContinueWith(static (completed, state) => 82dataflowBlockOptions.CancellationToken, _source.Completion, static (owningSource, _) => ((BufferBlock<T>)owningSource!).Complete(), this); 127_source.AddMessage(messageValue!); 171_source.AddException(exception); 189public IDisposable LinkTo(ITargetBlock<T> target, DataflowLinkOptions linkOptions) { return _source.LinkTo(target, linkOptions); } 192public bool TryReceive(Predicate<T>? filter, [MaybeNullWhen(false)] out T item) { return _source.TryReceive(filter, out item); } 195public bool TryReceiveAll([NotNullWhen(true)] out IList<T>? items) { return _source.TryReceiveAll(out items); } 198public int Count { get { return _source.OutputCount; } } 201public Task Completion { get { return _source.Completion; } } 206return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 212return _source.ReserveMessage(messageHeader, target); 218_source.ReleaseReservation(messageHeader, target); 273Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 295int maxMessagesPerTask = _source.DataflowBlockOptions.ActualMaxMessagesPerTask; 362_source.AddMessage(consumedValue!); 409thisBufferBlock._source.AddExceptions(exceptions); 412thisBufferBlock._source.Complete(); 418_source.Complete(); 424private int CountForDebugger { get { return _source.GetDebuggingInformation().OutputCount; } } 427public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 431$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, Count = {CountForDebugger}"; 450_sourceDebuggingInformation = bufferBlock._source.GetDebuggingInformation();