1 write to _source
System.Threading.Tasks.Dataflow (1)
Blocks\TransformBlock.cs (1)
109_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; } } 117_reorderingBuffer = new ReorderingBuffer<TOutput>(this, static (owningSource, message) => ((TransformBlock<TInput, TOutput>)owningSource)._source.AddMessage(message)); 145}, _source, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 151_source.Completion.ContinueWith(static (completed, state) => 205_source.AddMessage(outputItem!); 211_source.AddMessage(outputItem!); 309_source.AddMessage(outputItem!); 315_source.AddMessage(outputItem!); 343return _source.LinkTo(target, linkOptions); 349return _source.TryReceive(filter, out item); 353public bool TryReceiveAll([NotNullWhen(true)] out IList<TOutput>? items) { return _source.TryReceiveAll(out items); } 356public Task Completion { get { return _source.Completion; } } 362public int OutputCount { get { return _source.OutputCount; } } 373return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 379return _source.ReserveMessage(messageHeader, target); 385_source.ReleaseReservation(messageHeader, target); 391private int OutputCountForDebugger { get { return _source.GetDebuggingInformation().OutputCount; } } 394public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 398$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, InputCount = {InputCountForDebugger}, OutputCount = {OutputCountForDebugger}"; 420_sourceDebuggingInformation = transformBlock._source.GetDebuggingInformation();