1 write to _source
System.Threading.Tasks.Dataflow (1)
Blocks\TransformBlock.cs (1)
112_source = new SourceCore<TOutput>(this, dataflowBlockOptions,
20 references to _source
System.Threading.Tasks.Dataflow (20)
Blocks\TransformBlock.cs (20)
42private object ParallelSourceLock { get { return _source; } } 120_reorderingBuffer = new ReorderingBuffer<TOutput>(this, static (owningSource, message) => ((TransformBlock<TInput, TOutput>)owningSource)._source.AddMessage(message)); 148}, _source, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 154_source.Completion.ContinueWith(static (completed, state) => 208_source.AddMessage(outputItem!); 214_source.AddMessage(outputItem!); 312_source.AddMessage(outputItem!); 318_source.AddMessage(outputItem!); 349return _source.LinkTo(target, linkOptions); 355return _source.TryReceive(filter, out item); 359public bool TryReceiveAll([NotNullWhen(true)] out IList<TOutput>? items) { return _source.TryReceiveAll(out items); } 362public Task Completion { get { return _source.Completion; } } 368public int OutputCount { get { return _source.OutputCount; } } 379return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 385return _source.ReserveMessage(messageHeader, target); 391_source.ReleaseReservation(messageHeader, target); 397private int OutputCountForDebugger { get { return _source.GetDebuggingInformation().OutputCount; } } 400public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 404$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, InputCount = {InputCountForDebugger}, OutputCount = {OutputCountForDebugger}"; 426_sourceDebuggingInformation = transformBlock._source.GetDebuggingInformation();