2 instantiations of ObserversState
System.Threading.Tasks.Dataflow (2)
Base\DataflowBlock.cs (2)
2205
_observersState = new
ObserversState
(this);
2314
_observersState = new
ObserversState
(this);
7 references to ObserversState
System.Threading.Tasks.Dataflow (7)
Base\DataflowBlock.cs (7)
2197
private
ObserversState
_observersState;
2279
ObserversState
currentState = _observersState;
2307
ObserversState
currentState = _observersState;
2386
static (t, state) => ((
ObserversState
)state!).NotifyObserversOfCompletion(t.Exception!), this,
2396
var
ti = (
ObserversState
)state1!;
2399
static (_2, state2) => ((
ObserversState
)state2!).NotifyObserversOfCompletion(), state1,