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