13 references to TargetCoreOptions
System.Threading.Tasks.Dataflow (13)
Blocks\ActionBlock.cs (3)
107
null, dataflowBlockOptions,
TargetCoreOptions
.RepresentsBlockCompletion);
115
null, dataflowBlockOptions,
TargetCoreOptions
.RepresentsBlockCompletion |
TargetCoreOptions
.UsesAsyncCompletion);
Blocks\TransformBlock.cs (2)
128
_reorderingBuffer, dataflowBlockOptions,
TargetCoreOptions
.None);
135
_reorderingBuffer, dataflowBlockOptions,
TargetCoreOptions
.UsesAsyncCompletion);
Blocks\TransformManyBlock.cs (3)
71
Initialize(messageWithId => ProcessMessage(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer,
TargetCoreOptions
.None);
95
Initialize(messageWithId => ProcessMessageWithTask(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer,
TargetCoreOptions
.UsesAsyncCompletion);
104
TargetCoreOptions
targetCoreOptions)
Blocks\TransformManyBlock.IAsyncEnumerable.cs (1)
45
}, dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer,
TargetCoreOptions
.UsesAsyncCompletion);
Internal\TargetCore.cs (4)
72
private readonly
TargetCoreOptions
_targetCoreOptions;
111
TargetCoreOptions
targetCoreOptions)
286
return (_targetCoreOptions &
TargetCoreOptions
.UsesAsyncCompletion) != 0;
797
if ((_targetCoreOptions &
TargetCoreOptions
.RepresentsBlockCompletion) != 0 &&