8 instantiations of SourceCore
System.Threading.Tasks.Dataflow (8)
Blocks\BatchBlock.cs (1)
66
_source = new
SourceCore
<T[]>(this, dataflowBlockOptions,
Blocks\BatchedJoinBlock.cs (2)
67
_source = new
SourceCore
<Tuple<IList<T1>, IList<T2>>>(
315
_source = new
SourceCore
<Tuple<IList<T1>, IList<T2>, IList<T3>>>(
Blocks\BufferBlock.cs (1)
62
_source = new
SourceCore
<T>(this, dataflowBlockOptions,
Blocks\JoinBlock.cs (2)
62
_source = new
SourceCore
<Tuple<T1, T2>>(this, dataflowBlockOptions,
283
_source = new
SourceCore
<Tuple<T1, T2, T3>>(this, dataflowBlockOptions,
Blocks\TransformBlock.cs (1)
109
_source = new
SourceCore
<TOutput>(this, dataflowBlockOptions,
Blocks\TransformManyBlock.cs (1)
119
source = new
SourceCore
<TOutput>(this, dataflowBlockOptions,
31 references to SourceCore
System.Threading.Tasks.Dataflow (31)
Blocks\BatchBlock.cs (2)
31
private readonly
SourceCore
<T[]> _source;
193
private readonly
SourceCore
<T[]>.DebuggingInformation _sourceDebuggingInformation;
Blocks\BatchedJoinBlock.cs (4)
40
private readonly
SourceCore
<Tuple<IList<T1>, IList<T2>>> _source;
221
private readonly
SourceCore
<Tuple<IList<T1>, IList<T2>>>.DebuggingInformation _sourceDebuggingInformation;
285
private readonly
SourceCore
<Tuple<IList<T1>, IList<T2>, IList<T3>>> _source;
476
private readonly
SourceCore
<Tuple<IList<T1>, IList<T2>, IList<T3>>>.DebuggingInformation _sourceDebuggingInformation;
Blocks\BroadcastBlock.cs (1)
489
/// <typeparam name="TOutput">Specifies the type of data supplied by the <see cref="
SourceCore
{TOutput}"/>.</typeparam>
Blocks\BufferBlock.cs (2)
28
private readonly
SourceCore
<T> _source;
436
private readonly
SourceCore
<T>.DebuggingInformation _sourceDebuggingInformation;
Blocks\JoinBlock.cs (4)
36
private readonly
SourceCore
<Tuple<T1, T2>> _source;
199
private readonly
SourceCore
<Tuple<T1, T2>>.DebuggingInformation _sourceDebuggingInformation;
255
private readonly
SourceCore
<Tuple<T1, T2, T3>> _source;
423
private readonly
SourceCore
<Tuple<T1, T2, T3>>.DebuggingInformation _sourceDebuggingInformation;
Blocks\TransformBlock.cs (4)
32
private readonly
SourceCore
<TOutput> _source;
142
var
sourceCore = (
SourceCore
<TOutput>)state!;
411
private readonly
SourceCore
<TOutput>.DebuggingInformation _sourceDebuggingInformation;
Blocks\TransformManyBlock.cs (5)
37
private readonly
SourceCore
<TOutput> _source;
101
[NotNull] ref
SourceCore
<TOutput>? source,
141
var
sourceCore = (
SourceCore
<TOutput>)state!;
620
private readonly
SourceCore
<TOutput>.DebuggingInformation _sourceDebuggingInformation;
Internal\SourceCore.cs (9)
29
/// <typeparam name="TOutput">Specifies the type of data supplied by the <see cref="
SourceCore
{TOutput}"/>.</typeparam>
515
var
thisSourceCore = (
SourceCore
<TOutput>)state!;
753
_taskForOutputProcessing = new Task(static thisSourceCore => ((
SourceCore
<TOutput>)thisSourceCore!).OfferMessagesLoopCore(), this,
778
var
thisSourceCore = (
SourceCore
<TOutput>)state!;
919
Task.Factory.StartNew(static state => ((
SourceCore
<TOutput>)state!).CompleteBlockOncePossible(),
994
private readonly
SourceCore
<TOutput> _source;
998
internal DebuggingInformation(
SourceCore
<TOutput> source) { _source = source; }