1 write to _target
System.Threading.Tasks.Dataflow (1)
Internal\SpscTargetCore.cs (1)
388internal DebuggingInformation(SpscTargetCore<TInput> target) { _target = target; }
6 references to _target
System.Threading.Tasks.Dataflow (6)
Internal\SpscTargetCore.cs (6)
391internal IEnumerable<TInput> InputQueue { get { return _target._messages.ToList(); } } 394internal int CurrentDegreeOfParallelism { get { return _target._activeConsumer != null && !_target.Completion.IsCompleted ? 1 : 0; } } 396internal ExecutionDataflowBlockOptions DataflowBlockOptions { get { return _target._dataflowBlockOptions; } } 398internal bool IsDecliningPermanently { get { return _target._decliningPermanently; } } 400internal bool IsCompleted { get { return _target.Completion.IsCompleted; } }