1 write to _source
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
1572_source = source;
10 references to _source
System.Threading.Tasks.Dataflow (10)
Base\DataflowBlock.cs (10)
1598public Task Completion { get { return _source.Completion; } } 1603return _source.LinkTo(target, linkOptions); 1609var receivableSource = _source as IReceivableSourceBlock<TOutput>; 1619var receivableSource = _source as IReceivableSourceBlock<TOutput>; 1629return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 1635return _source.ReserveMessage(messageHeader, target); 1641_source.ReleaseReservation(messageHeader, target); 1650var displaySource = _source as IDebuggerDisplay; 1651return $"{Common.GetNameForDebugger(this)} Target = \"{(displayTarget != null ? displayTarget.Content : _target)}\", Source = \"{(displaySource != null ? displaySource.Content : _source)}\""; 1674public ISourceBlock<TOutput> Source { get { return _propagator._source; } }