5 instantiations of TargetCore
System.Threading.Tasks.Dataflow (5)
Blocks\ActionBlock.cs (2)
105_defaultTarget = new TargetCore<TInput>(this, 113_defaultTarget = new TargetCore<TInput>(this,
Blocks\TransformBlock.cs (2)
126_target = new TargetCore<TInput>(this, 133_target = new TargetCore<TInput>(this,
Blocks\TransformManyBlock.cs (1)
132target = new TargetCore<TInput>(this, processMessageAction, _reorderingBuffer, dataflowBlockOptions, targetCoreOptions);
20 references to TargetCore
System.Threading.Tasks.Dataflow (20)
Blocks\ActionBlock.cs (3)
28private readonly TargetCore<TInput>? _defaultTarget; 120dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), _defaultTarget); 328private readonly TargetCore<TInput>.DebuggingInformation? _defaultDebugInfo;
Blocks\TransformBlock.cs (3)
28private readonly TargetCore<TInput> _target; 163dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), _target); 415private readonly TargetCore<TInput>.DebuggingInformation _targetDebuggingInformation;
Blocks\TransformManyBlock.cs (5)
30private readonly TargetCore<TInput> _target; 102[NotNull] ref TargetCore<TInput>? target, 159dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), target); 354TargetCore<TInput> target = _target; 621private readonly TargetCore<TInput>.DebuggingInformation _targetDebuggingInformation;
Blocks\TransformManyBlock.IAsyncEnumerable.cs (1)
126TargetCore<TInput> target = _target;
Internal\SpscTargetCore.cs (1)
42/// <typeparam name="TInput">Specifies the type of data accepted by the <see cref="TargetCore{TInput}"/>.</typeparam>
Internal\TargetCore.cs (7)
44/// <typeparam name="TInput">Specifies the type of data accepted by the <see cref="TargetCore{TInput}"/>.</typeparam> 51private static readonly Common.KeepAlivePredicate<TargetCore<TInput>, KeyValuePair<TInput, long>> _keepAlivePredicate = 52(TargetCore<TInput> thisTargetCore, out KeyValuePair<TInput, long> messageWithId) => 372var taskForInputProcessing = new Task(static thisTargetCore => ((TargetCore<TInput>)thisTargetCore!).ProcessMessagesLoopCore(), this, 745Task.Factory.StartNew(static state => ((TargetCore<TInput>)state!).CompleteBlockOncePossible(), 847private readonly TargetCore<TInput> _target; 851internal DebuggingInformation(TargetCore<TInput> target) { _target = target; }