3 writes to _source
System.Threading.Tasks.Dataflow (3)
Blocks\TransformManyBlock.cs (2)
71Initialize(messageWithId => ProcessMessage(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.None); 95Initialize(messageWithId => ProcessMessageWithTask(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.UsesAsyncCompletion);
Blocks\TransformManyBlock.IAsyncEnumerable.cs (1)
45}, dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.UsesAsyncCompletion);
25 references to _source
System.Threading.Tasks.Dataflow (25)
Blocks\TransformManyBlock.cs (21)
47private object ParallelSourceLock { get { return _source; } } 128this, static (source, messages) => ((TransformManyBlock<TInput, TOutput>)source)._source.AddMessages(messages)); 247_source.DataflowBlockOptions.TaskScheduler); 444_source.AddMessages(outputItems); 450_source.AddMessages(outputItems); 489_source.AddMessage(item); 495_source.AddMessage(item); 511_source.AddMessage(item); 519_source.AddMessage(item); 559public IDisposable LinkTo(ITargetBlock<TOutput> target, DataflowLinkOptions linkOptions) { return _source.LinkTo(target, linkOptions); } 562public bool TryReceive(Predicate<TOutput>? filter, [MaybeNullWhen(false)] out TOutput item) { return _source.TryReceive(filter, out item); } 565public bool TryReceiveAll([NotNullWhen(true)] out IList<TOutput>? items) { return _source.TryReceiveAll(out items); } 568public Task Completion { get { return _source.Completion; } } 574public int OutputCount { get { return _source.OutputCount; } } 585return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 591return _source.ReserveMessage(messageHeader, target); 597_source.ReleaseReservation(messageHeader, target); 603private int OutputCountForDebugger { get { return _source.GetDebuggingInformation().OutputCount; } } 606public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 610$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, InputCount = {InputCountForDebugger}, OutputCount = {OutputCountForDebugger}"; 632_sourceDebuggingInformation = transformManyBlock._source.GetDebuggingInformation();
Blocks\TransformManyBlock.IAsyncEnumerable.cs (4)
228_source.AddMessage(item); 234_source.AddMessage(item); 254_source.AddMessage(item); 263_source.AddMessage(item);