3 writes to OutstandingTransfers
System.Threading.Tasks.Dataflow (3)
Internal\TargetCore.cs (3)
428_boundingState.OutstandingTransfers--; // was incremented in TryConsumePostponedMessage 665_boundingState.OutstandingTransfers++; // temporarily force postponement until we've successfully consumed the element 691_boundingState!.OutstandingTransfers--;
4 references to OutstandingTransfers
System.Threading.Tasks.Dataflow (4)
Internal\TargetCore.cs (4)
203(_boundingState.OutstandingTransfers == 0 && _boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0)) 425_boundingState!.OutstandingTransfers > 0 426&& _boundingState.OutstandingTransfers <= _dataflowBlockOptions.ActualMaxDegreeOfParallelism, 664Debug.Assert(_boundingState.OutstandingTransfers >= 0, "Expected TryConsumePostponedMessage to not be negative.");