1 write to _source
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2203
_source
= source;
6 references to _source
System.Threading.Tasks.Dataflow (6)
Base\DataflowBlock.cs (6)
2211
Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(
_source
);
2226
Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(
_source
);
2249
_observersState.Unlinker =
_source
.LinkTo(_observersState.Target);
2324
var displaySource =
_source
as IDebuggerDisplay;
2325
return $"Observers = {_observersState.Observers.Count}, Block = \"{(displaySource != null ? displaySource.Content :
_source
)}\"";
2392
Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(Observable.
_source
);