13 references to CountIsLessThanBound
System.Threading.Tasks.Dataflow (13)
Blocks\BatchBlock.cs (1)
373
(_boundingState.
CountIsLessThanBound
&& _nonGreedyState!.PostponedMessages.Count == 0 && _nonGreedyState.TaskForInputProcessing == null)))
Blocks\BroadcastBlock.cs (3)
183
(_boundingState.
CountIsLessThanBound
&& _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null))
249
_boundingState.
CountIsLessThanBound
)
338
if (!_boundingState.
CountIsLessThanBound
) return false;
Blocks\BufferBlock.cs (3)
111
(_boundingState.
CountIsLessThanBound
&& _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null))
250
_boundingState.
CountIsLessThanBound
)
341
if (!_boundingState.
CountIsLessThanBound
) return false;
Blocks\JoinBlock.cs (3)
698
bool boundingCapacityAvailable = _sharedResources._boundingState.
CountIsLessThanBound
|| !hasTheHighestNumberOfMessagesAvailable;
838
((_sharedResources._boundingState.
CountIsLessThanBound
|| !HasTheHighestNumberOfMessagesAvailable) &&
1116
bool boundingCapacityAvailable = _boundingState.
CountIsLessThanBound
;
Internal\TargetCore.cs (3)
203
(_boundingState.OutstandingTransfers == 0 && _boundingState.
CountIsLessThanBound
&& _boundingState.PostponedMessages.Count == 0))
360
(!_decliningPermanently && _boundingState != null && _boundingState.
CountIsLessThanBound
&& _boundingState.PostponedMessages.Count > 0);
651
if (!_boundingState!.
CountIsLessThanBound
|| !_boundingState.PostponedMessages.TryPop(out element))