1 write to _source
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
1531_source = source;
10 references to _source
System.Threading.Tasks.Dataflow (10)
Base\DataflowBlock.cs (10)
1554public Task Completion { get { return _source.Completion; } } 1559return _source.LinkTo(target, linkOptions); 1565var receivableSource = _source as IReceivableSourceBlock<TOutput>; 1575var receivableSource = _source as IReceivableSourceBlock<TOutput>; 1585return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 1591return _source.ReserveMessage(messageHeader, target); 1597_source.ReleaseReservation(messageHeader, target); 1606var displaySource = _source as IDebuggerDisplay; 1607return $"{Common.GetNameForDebugger(this)} Target = \"{(displayTarget != null ? displayTarget.Content : _target)}\", Source = \"{(displaySource != null ? displaySource.Content : _source)}\""; 1630public ISourceBlock<TOutput> Source { get { return _propagator._source; } }