1 write to _consumersCancellationTokenSource
System.Collections.Concurrent (1)
System\Collections\Concurrent\BlockingCollection.cs (1)
217_consumersCancellationTokenSource = new CancellationTokenSource();
5 references to _consumersCancellationTokenSource
System.Collections.Concurrent (5)
System\Collections\Concurrent\BlockingCollection.cs (5)
207[MemberNotNull(nameof(_consumersCancellationTokenSource))] 667linkedTokenSource ??= CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, _consumersCancellationTokenSource.Token); 1076tokensList.Add(collections[i]._consumersCancellationTokenSource.Token); 1478_consumersCancellationTokenSource.Cancel(); 1619using CancellationTokenSource linkedTokenSource = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, _consumersCancellationTokenSource.Token);