1 write to _source
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
1530_source = source;
10 references to _source
System.Threading.Tasks.Dataflow (10)
Base\DataflowBlock.cs (10)
1553public Task Completion { get { return _source.Completion; } } 1558return _source.LinkTo(target, linkOptions); 1564var receivableSource = _source as IReceivableSourceBlock<TOutput>; 1574var receivableSource = _source as IReceivableSourceBlock<TOutput>; 1584return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 1590return _source.ReserveMessage(messageHeader, target); 1596_source.ReleaseReservation(messageHeader, target); 1605var displaySource = _source as IDebuggerDisplay; 1606return $"{Common.GetNameForDebugger(this)} Target = \"{(displayTarget != null ? displayTarget.Content : _target)}\", Source = \"{(displaySource != null ? displaySource.Content : _source)}\""; 1629public ISourceBlock<TOutput> Source { get { return _propagator._source; } }