Count

24 references to Count

System.Threading.Tasks.Dataflow (24)

Blocks\BatchBlock.cs (8)

376(_boundingState.CountIsLessThanBound && _nonGreedyState!.PostponedMessages.Count == 0 && _nonGreedyState.TaskForInputProcessing == null))) 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); 778postponed.Count == 0 || 780(!allowFewerThanBatchSize && (postponed.Count < _batchSize || boundedCapacityAvailable < _batchSize))) 895postponed.Count == 0 ||

Blocks\BroadcastBlock.cs (4)

189(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 254_boundingState.PostponedMessages.Count > 0 && 268_boundingState.PostponedMessages.Count); 386if (_boundingState != null && _boundingState.PostponedMessages.Count > 0)

Blocks\BufferBlock.cs (4)

114(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 255_boundingState.PostponedMessages.Count > 0 && 269_boundingState.PostponedMessages.Count); 389if (_boundingState != null && _boundingState.PostponedMessages.Count > 0)

Blocks\JoinBlock.cs (3)

577return _nonGreedy != null && _nonGreedy.PostponedMessages.Count > 0; 587return !_sharedResources._dataflowBlockOptions.Greedy ? _nonGreedy!.PostponedMessages.Count : _messages!.Count; 851_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));