1 write to _target
System.Threading.Tasks.Dataflow (1)
Internal\TargetCore.cs (1)
851internal DebuggingInformation(TargetCore<TInput> target) { _target = target; }
8 references to _target
System.Threading.Tasks.Dataflow (8)
Internal\TargetCore.cs (8)
854internal int InputCount { get { return _target._messages.Count; } } 856internal IEnumerable<TInput> InputQueue { get { return _target._messages.Select(static kvp => kvp.Key).ToList(); } } 861get { return _target._boundingState?.PostponedMessages; } 865internal int CurrentDegreeOfParallelism { get { return _target._numberOfOutstandingOperations - _target._numberOfOutstandingServiceTasks; } } 868internal ExecutionDataflowBlockOptions DataflowBlockOptions { get { return _target._dataflowBlockOptions; } } 870internal bool IsDecliningPermanently { get { return _target._decliningPermanently; } } 872internal bool IsCompleted { get { return _target.Completion.IsCompleted; } }