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