2 writes to _decliningPermanently
System.Threading.Tasks.Dataflow (2)
Internal\SourceCore.cs (2)
506_decliningPermanently = true; 772_decliningPermanently = true;
5 references to _decliningPermanently
System.Threading.Tasks.Dataflow (5)
Internal\SourceCore.cs (5)
386if (_decliningPermanently) return; 411if (_decliningPermanently) return; 879(HasExceptions && _decliningPermanently); 891if (_decliningPermanently && // declining permanently, so no more messages will arrive 907_decliningPermanently && _taskForOutputProcessing == null && _nextMessageReservedFor == null,