1 write to _source
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
82_source = new BroadcastingSourceCore<T>(this, cloningFunction, dataflowBlockOptions, onItemsRemoved);
23 references to _source
System.Threading.Tasks.Dataflow (23)
Blocks\BroadcastBlock.cs (23)
47private object IncomingLock { get { return _source; } } 88_source.Completion.ContinueWith(static (completed, state) => 97dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BroadcastBlock<T>)state!).Complete(), this); 130_source.AddException(exception); 148public IDisposable LinkTo(ITargetBlock<T> target, DataflowLinkOptions linkOptions) { return _source.LinkTo(target, linkOptions); } 151public bool TryReceive(Predicate<T>? filter, [MaybeNullWhen(false)] out T item) { return _source.TryReceive(filter, out item); } 154bool IReceivableSourceBlock<T>.TryReceiveAll([NotNullWhen(true)] out IList<T>? items) { return _source.TryReceiveAll(out items); } 157public Task Completion { get { return _source.Completion; } } 196_source.AddMessage(messageValue!); 266Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 287int maxMessagesPerTask = _source.DataflowBlockOptions.ActualMaxMessagesPerTask; 353_source.AddMessage(consumedValue!); 400thisBroadcastBlock._source.AddExceptions(exceptions); 403thisBroadcastBlock._source.Complete(); 409_source.Complete(); 417return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 423return _source.ReserveMessage(messageHeader, target); 429_source.ReleaseReservation(messageHeader, target); 433private bool HasValueForDebugger { get { return _source.GetDebuggingInformation().HasValue; } } 435private T ValueForDebugger { get { return _source.GetDebuggingInformation().Value; } } 438public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 441private object DebuggerDisplayContent => $"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, HasValue = {HasValueForDebugger}, Value = {ValueForDebugger}"; 460_sourceDebuggingInformation = broadcastBlock._source.GetDebuggingInformation();