1 write to PostponedMessages
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
294PostponedMessages = new QueuedMap<ISourceBlock<T>, DataflowMessageHeader>(batchSize);
10 references to PostponedMessages
System.Threading.Tasks.Dataflow (10)
Blocks\BatchBlock.cs (10)
376(_boundingState.CountIsLessThanBound && _nonGreedyState!.PostponedMessages.Count == 0 && _nonGreedyState.TaskForInputProcessing == null))) 412_nonGreedyState.PostponedMessages.Push(source, messageHeader); 535targetCore._nonGreedyState.PostponedMessages, 592if (_nonGreedyState.AcceptFewerThanBatchSize && _nonGreedyState.PostponedMessages.Count > 0 && boundedCapacityAvailable > 0) 602if (_nonGreedyState.PostponedMessages.Count > 0 && boundedCapacityAvailable > 0) return true; 607if (_nonGreedyState.PostponedMessages.Count >= neededMessageCountToCompleteBatch && 649_messages.Count + _nonGreedyState.PostponedMessages.Count); 760QueuedMap<ISourceBlock<T>, DataflowMessageHeader> postponed = _nonGreedyState.PostponedMessages; 878QueuedMap<ISourceBlock<T>, DataflowMessageHeader> postponed = _nonGreedyState.PostponedMessages; 1184public QueuedMap<ISourceBlock<T>, DataflowMessageHeader>? PostponedMessages { get { return _target._nonGreedyState?.PostponedMessages; } }