4 writes to Observers
System.Threading.Tasks.Dataflow (4)
Base\DataflowBlock.cs (4)
2245_observersState.Observers = _observersState.Observers.Add(observer); 2252_observersState.Observers = ImmutableArray<IObserver<TOutput>>.Empty; 2295currentState.Observers = currentState.Observers.Remove(observer); 2482Observers = ImmutableArray<IObserver<TOutput>>.Empty;
10 references to Observers
System.Threading.Tasks.Dataflow (10)
Base\DataflowBlock.cs (10)
2245_observersState.Observers = _observersState.Observers.Add(observer); 2246if (_observersState.Observers.Count == 1) 2282if (!currentState.Observers.Contains(observer)) return; 2285if (currentState.Observers.Count == 1) 2295currentState.Observers = currentState.Observers.Remove(observer); 2312ImmutableArray<IObserver<TOutput>> currentObservers = currentState.Observers; 2325return $"Observers = {_observersState.Observers.Count}, Block = \"{(displaySource != null ? displaySource.Content : _source)}\""; 2347public IObserver<TOutput>[] Observers { get { return _observable._observersState.Observers.ToArray(); } } 2412lock (Observable._SubscriptionLock) currentObservers = Observers; 2480currentObservers = Observers;