1 write to _target
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
1177public DebuggingInformation(BatchBlockTargetCore target) { _target = target; }
6 references to _target
System.Threading.Tasks.Dataflow (6)
Blocks\BatchBlock.cs (6)
1180public IEnumerable<T> InputQueue { get { return _target._messages.ToList(); } } 1182public Task? TaskForInputProcessing { get { return _target._nonGreedyState?.TaskForInputProcessing; } } 1184public QueuedMap<ISourceBlock<T>, DataflowMessageHeader>? PostponedMessages { get { return _target._nonGreedyState?.PostponedMessages; } } 1186public bool IsDecliningPermanently { get { return _target._decliningPermanently; } } 1188public GroupingDataflowBlockOptions DataflowBlockOptions { get { return _target._dataflowBlockOptions; } } 1190public long NumberOfBatchesCompleted { get { return _target._batchesCompleted; } }