1 write to _exceptions
System.Threading.Tasks.Dataflow (1)
Internal\SpscTargetCore.cs (1)
312lock (LazyInitializer.EnsureInitialized(ref _exceptions, static () => new List<Exception>()))
8 references to _exceptions
System.Threading.Tasks.Dataflow (8)
Internal\SpscTargetCore.cs (8)
211_exceptions == null && 234if (!_messages.IsEmpty && _exceptions == null && (messagesProcessed < maxMessagesToProcess)) 243if ((wasDecliningPermanently && _messages.IsEmpty) || _exceptions != null) 267_exceptions != null) // exceptions/completion to be processed 315_exceptions.Add(exception); 331if (_exceptions != null) 334lock (_exceptions) exceptions = _exceptions.ToArray();