8 references to PostponedMessages
System.Threading.Tasks.Dataflow (8)
Blocks\JoinBlock.cs (8)
577return _nonGreedy != null && _nonGreedy.PostponedMessages.Count > 0; 587return !_sharedResources._dataflowBlockOptions.Greedy ? _nonGreedy!.PostponedMessages.Count : _messages!.Count; 624if (!_nonGreedy!.PostponedMessages.TryPop(out next)) return false; 643if (!_nonGreedy.PostponedMessages.TryPop(out next)) return false; 712!boundingCapacityAvailable || !_nonGreedy!.PostponedMessages.TryPop(out next)) 806Common.ReleaseAllPostponedMessages(this, _nonGreedy.PostponedMessages, ref exceptions); 851_nonGreedy!.PostponedMessages.Count == 0 && _sharedResources._taskForInputProcessing == null))) 882_nonGreedy.PostponedMessages.Push(source, messageHeader);