Count

24 references to Count

System.Threading.Tasks.Dataflow (24)

Blocks\BatchBlock.cs (8)

373(_boundingState.CountIsLessThanBound && _nonGreedyState!.PostponedMessages.Count == 0 && _nonGreedyState.TaskForInputProcessing == null))) 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); 775postponed.Count == 0 || 777(!allowFewerThanBatchSize && (postponed.Count < _batchSize || boundedCapacityAvailable < _batchSize))) 892postponed.Count == 0 ||

Blocks\BroadcastBlock.cs (4)

183(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 248_boundingState.PostponedMessages.Count > 0 && 262_boundingState.PostponedMessages.Count); 380if (_boundingState != null && _boundingState.PostponedMessages.Count > 0)

Blocks\BufferBlock.cs (4)

111(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 249_boundingState.PostponedMessages.Count > 0 && 263_boundingState.PostponedMessages.Count); 383if (_boundingState != null && _boundingState.PostponedMessages.Count > 0)

Blocks\JoinBlock.cs (3)

565return _nonGreedy != null && _nonGreedy.PostponedMessages.Count > 0; 575return !_sharedResources._dataflowBlockOptions.Greedy ? _nonGreedy!.PostponedMessages.Count : _messages!.Count; 839_nonGreedy!.PostponedMessages.Count == 0 && _sharedResources._taskForInputProcessing == null)))

Internal\Common.cs (2)

507int initialCount = postponedMessages.Count; 667private int PostponedMessagesCountForDebugger { get { return PostponedMessages.Count; } }

Internal\TargetCore.cs (3)

203(_boundingState.OutstandingTransfers == 0 && _boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0)) 360(!_decliningPermanently && _boundingState != null && _boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count > 0); 380_messages.Count + (_boundingState != null ? _boundingState.PostponedMessages.Count : 0));