1 write to PostponedMessages
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
291PostponedMessages = new QueuedMap<ISourceBlock<T>, DataflowMessageHeader>(batchSize);
10 references to PostponedMessages
System.Threading.Tasks.Dataflow (10)
Blocks\BatchBlock.cs (10)
373(_boundingState.CountIsLessThanBound && _nonGreedyState!.PostponedMessages.Count == 0 && _nonGreedyState.TaskForInputProcessing == null))) 409_nonGreedyState.PostponedMessages.Push(source, messageHeader); 532targetCore._nonGreedyState.PostponedMessages, 589if (_nonGreedyState.AcceptFewerThanBatchSize && _nonGreedyState.PostponedMessages.Count > 0 && boundedCapacityAvailable > 0) 599if (_nonGreedyState.PostponedMessages.Count > 0 && boundedCapacityAvailable > 0) return true; 604if (_nonGreedyState.PostponedMessages.Count >= neededMessageCountToCompleteBatch && 646_messages.Count + _nonGreedyState.PostponedMessages.Count); 757QueuedMap<ISourceBlock<T>, DataflowMessageHeader> postponed = _nonGreedyState.PostponedMessages; 875QueuedMap<ISourceBlock<T>, DataflowMessageHeader> postponed = _nonGreedyState.PostponedMessages; 1181public QueuedMap<ISourceBlock<T>, DataflowMessageHeader>? PostponedMessages { get { return _target._nonGreedyState?.PostponedMessages; } }