2 writes to _observersState
System.Threading.Tasks.Dataflow (2)
Base\DataflowBlock.cs (2)
2286_observersState = new ObserversState(this); 2398_observersState = new ObserversState(this);
13 references to _observersState
System.Threading.Tasks.Dataflow (13)
Base\DataflowBlock.cs (13)
2322_observersState.Target.Completion.IsCompleted) 2330_observersState.Observers = _observersState.Observers.Add(observer); 2331if (_observersState.Observers.Count == 1) 2333Debug.Assert(_observersState.Unlinker == null, "The source should not be linked to the target."); 2334_observersState.Unlinker = _source.LinkTo(_observersState.Target); 2335if (_observersState.Unlinker == null) 2337_observersState.Observers = ImmutableArray<IObserver<TOutput>>.Empty; 2363ObserversState currentState = _observersState; 2391ObserversState currentState = _observersState; 2410return $"Observers = {_observersState.Observers.Count}, Block = \"{(displaySource != null ? displaySource.Content : _source)}\""; 2432public IObserver<TOutput>[] Observers { get { return _observable._observersState.Observers.ToArray(); } }