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