2 instantiations of ObserversState
System.Threading.Tasks.Dataflow (2)
Base\DataflowBlock.cs (2)
2286
_observersState = new
ObserversState
(this);
2398
_observersState = new
ObserversState
(this);
7 references to ObserversState
System.Threading.Tasks.Dataflow (7)
Base\DataflowBlock.cs (7)
2278
private
ObserversState
_observersState;
2363
ObserversState
currentState = _observersState;
2391
ObserversState
currentState = _observersState;
2470
static (t, state) => ((
ObserversState
)state!).NotifyObserversOfCompletion(t.Exception!), this,
2480
var
ti = (
ObserversState
)state1!;
2483
static (_2, state2) => ((
ObserversState
)state2!).NotifyObserversOfCompletion(), state1,