1 write to Observable
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2380Observable = observable;
7 references to Observable
System.Threading.Tasks.Dataflow (7)
Base\DataflowBlock.cs (7)
2393Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(Observable._source); 2410Common.ContractAssertMonitorStatus(Observable._SubscriptionLock, held: false); 2413lock (Observable._SubscriptionLock) currentObservers = Observers; 2472Common.ContractAssertMonitorStatus(Observable._SubscriptionLock, held: false); 2476lock (Observable._SubscriptionLock) 2482if (targetException != null) Observable.ResetObserverState(); 2490Exception? error = targetException ?? Observable.GetCompletionError();