1 write to Observable
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2464
Observable
= observable;
7 references to Observable
System.Threading.Tasks.Dataflow (7)
Base\DataflowBlock.cs (7)
2477
Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(
Observable
._source);
2494
Common.ContractAssertMonitorStatus(
Observable
._SubscriptionLock, held: false);
2497
lock (
Observable
._SubscriptionLock) currentObservers = Observers;
2556
Common.ContractAssertMonitorStatus(
Observable
._SubscriptionLock, held: false);
2560
lock (
Observable
._SubscriptionLock)
2566
if (targetException != null)
Observable
.ResetObserverState();
2574
Exception? error = targetException ??
Observable
.GetCompletionError();