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)
42}, 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); 556public IDisposable LinkTo(ITargetBlock<TOutput> target, DataflowLinkOptions linkOptions) { return _source.LinkTo(target, linkOptions); } 559public bool TryReceive(Predicate<TOutput>? filter, [MaybeNullWhen(false)] out TOutput item) { return _source.TryReceive(filter, out item); } 562public bool TryReceiveAll([NotNullWhen(true)] out IList<TOutput>? items) { return _source.TryReceiveAll(out items); } 565public Task Completion { get { return _source.Completion; } } 571public int OutputCount { get { return _source.OutputCount; } } 582return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 588return _source.ReserveMessage(messageHeader, target); 594_source.ReleaseReservation(messageHeader, target); 600private int OutputCountForDebugger { get { return _source.GetDebuggingInformation().OutputCount; } } 603public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 607$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, InputCount = {InputCountForDebugger}, OutputCount = {OutputCountForDebugger}"; 629_sourceDebuggingInformation = transformManyBlock._source.GetDebuggingInformation();
Blocks\TransformManyBlock.IAsyncEnumerable.cs (4)
225_source.AddMessage(item); 231_source.AddMessage(item); 251_source.AddMessage(item); 260_source.AddMessage(item);