8 references to PostponedMessages
System.Threading.Tasks.Dataflow (8)
Blocks\JoinBlock.cs (8)
565return _nonGreedy != null && _nonGreedy.PostponedMessages.Count > 0; 575return !_sharedResources._dataflowBlockOptions.Greedy ? _nonGreedy!.PostponedMessages.Count : _messages!.Count; 612if (!_nonGreedy!.PostponedMessages.TryPop(out next)) return false; 631if (!_nonGreedy.PostponedMessages.TryPop(out next)) return false; 700!boundingCapacityAvailable || !_nonGreedy!.PostponedMessages.TryPop(out next)) 794Common.ReleaseAllPostponedMessages(this, _nonGreedy.PostponedMessages, ref exceptions); 839_nonGreedy!.PostponedMessages.Count == 0 && _sharedResources._taskForInputProcessing == null))) 870_nonGreedy.PostponedMessages.Push(source, messageHeader);