1 write to _source
System.Threading.Tasks.Dataflow (1)
Internal\SourceCore.cs (1)
1004internal DebuggingInformation(SourceCore<TOutput> source) { _source = source; }
7 references to _source
System.Threading.Tasks.Dataflow (7)
Internal\SourceCore.cs (7)
1007internal int OutputCount { get { return _source._messages.Count; } } 1009internal IEnumerable<TOutput> OutputQueue { get { return _source._messages.ToList(); } } 1011internal Task? TaskForOutputProcessing { get { return _source._taskForOutputProcessing; } } 1014internal DataflowBlockOptions DataflowBlockOptions { get { return _source._dataflowBlockOptions; } } 1017internal bool IsCompleted { get { return _source.Completion.IsCompleted; } } 1020internal TargetRegistry<TOutput> LinkedTargets { get { return _source._targetRegistry; } } 1022internal ITargetBlock<TOutput>? NextMessageReservedFor { get { return _source._nextMessageReservedFor; } }