1 write to _source
System.Threading.Tasks.Dataflow (1)
Blocks\TransformBlock.cs (1)
108_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; } } 116_reorderingBuffer = new ReorderingBuffer<TOutput>(this, static (owningSource, message) => ((TransformBlock<TInput, TOutput>)owningSource)._source.AddMessage(message)); 144}, _source, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 150_source.Completion.ContinueWith(static (completed, state) => 204_source.AddMessage(outputItem!); 210_source.AddMessage(outputItem!); 308_source.AddMessage(outputItem!); 314_source.AddMessage(outputItem!); 342return _source.LinkTo(target, linkOptions); 348return _source.TryReceive(filter, out item); 352public bool TryReceiveAll([NotNullWhen(true)] out IList<TOutput>? items) { return _source.TryReceiveAll(out items); } 355public Task Completion { get { return _source.Completion; } } 361public int OutputCount { get { return _source.OutputCount; } } 372return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 378return _source.ReserveMessage(messageHeader, target); 384_source.ReleaseReservation(messageHeader, target); 390private int OutputCountForDebugger { get { return _source.GetDebuggingInformation().OutputCount; } } 393public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 397$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, InputCount = {InputCountForDebugger}, OutputCount = {OutputCountForDebugger}"; 419_sourceDebuggingInformation = transformBlock._source.GetDebuggingInformation();