1 write to _source
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
85_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; } } 91_source.Completion.ContinueWith(static (completed, state) => 100dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BroadcastBlock<T>)state!).Complete(), this); 136_source.AddException(exception); 154public IDisposable LinkTo(ITargetBlock<T> target, DataflowLinkOptions linkOptions) { return _source.LinkTo(target, linkOptions); } 157public bool TryReceive(Predicate<T>? filter, [MaybeNullWhen(false)] out T item) { return _source.TryReceive(filter, out item); } 160bool IReceivableSourceBlock<T>.TryReceiveAll([NotNullWhen(true)] out IList<T>? items) { return _source.TryReceiveAll(out items); } 163public Task Completion { get { return _source.Completion; } } 202_source.AddMessage(messageValue!); 272Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 293int maxMessagesPerTask = _source.DataflowBlockOptions.ActualMaxMessagesPerTask; 359_source.AddMessage(consumedValue!); 406thisBroadcastBlock._source.AddExceptions(exceptions); 409thisBroadcastBlock._source.Complete(); 415_source.Complete(); 423return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 429return _source.ReserveMessage(messageHeader, target); 435_source.ReleaseReservation(messageHeader, target); 439private bool HasValueForDebugger { get { return _source.GetDebuggingInformation().HasValue; } } 441private T ValueForDebugger { get { return _source.GetDebuggingInformation().Value; } } 444public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 447private object DebuggerDisplayContent => $"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, HasValue = {HasValueForDebugger}, Value = {ValueForDebugger}"; 466_sourceDebuggingInformation = broadcastBlock._source.GetDebuggingInformation();