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);
2331
if (
_observersState
.Observers.Count == 1)
2333
Debug.Assert(
_observersState
.Unlinker == null, "The source should not be linked to the target.");
2334
_observersState
.Unlinker = _source.LinkTo(
_observersState
.Target);
2335
if (
_observersState
.Unlinker == null)
2337
_observersState
.Observers = ImmutableArray<IObserver<TOutput>>.Empty;
2363
ObserversState currentState =
_observersState
;
2391
ObserversState currentState =
_observersState
;
2410
return $"Observers = {
_observersState
.Observers.Count}, Block = \"{(displaySource != null ? displaySource.Content : _source)}\"";
2432
public IObserver<TOutput>[] Observers { get { return _observable.
_observersState
.Observers.ToArray(); } }