1 write to _source
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2201
_source
= source;
6 references to _source
System.Threading.Tasks.Dataflow (6)
Base\DataflowBlock.cs (6)
2209
Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(
_source
);
2224
Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(
_source
);
2247
_observersState.Unlinker =
_source
.LinkTo(_observersState.Target);
2322
var displaySource =
_source
as IDebuggerDisplay;
2323
return $"Observers = {_observersState.Observers.Count}, Block = \"{(displaySource != null ? displaySource.Content :
_source
)}\"";
2390
Task? sourceCompletionTask = Common.GetPotentiallyNotSupportedCompletionTask(Observable.
_source
);