13 references to CountIsLessThanBound
System.Threading.Tasks.Dataflow (13)
Blocks\BatchBlock.cs (1)
376
(_boundingState.
CountIsLessThanBound
&& _nonGreedyState!.PostponedMessages.Count == 0 && _nonGreedyState.TaskForInputProcessing == null)))
Blocks\BroadcastBlock.cs (3)
189
(_boundingState.
CountIsLessThanBound
&& _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null))
255
_boundingState.
CountIsLessThanBound
)
344
if (!_boundingState.
CountIsLessThanBound
) return false;
Blocks\BufferBlock.cs (3)
114
(_boundingState.
CountIsLessThanBound
&& _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null))
256
_boundingState.
CountIsLessThanBound
)
347
if (!_boundingState.
CountIsLessThanBound
) return false;
Blocks\JoinBlock.cs (3)
710
bool boundingCapacityAvailable = _sharedResources._boundingState.
CountIsLessThanBound
|| !hasTheHighestNumberOfMessagesAvailable;
850
((_sharedResources._boundingState.
CountIsLessThanBound
|| !HasTheHighestNumberOfMessagesAvailable) &&
1131
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))