2 writes to _decliningPermanently
System.Threading.Tasks.Dataflow (2)
Internal\SourceCore.cs (2)
512_decliningPermanently = true; 778_decliningPermanently = true;
5 references to _decliningPermanently
System.Threading.Tasks.Dataflow (5)
Internal\SourceCore.cs (5)
392if (_decliningPermanently) return; 417if (_decliningPermanently) return; 885(HasExceptions && _decliningPermanently); 897if (_decliningPermanently && // declining permanently, so no more messages will arrive 913_decliningPermanently && _taskForOutputProcessing == null && _nextMessageReservedFor == null,