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>>>(
318
_source = new
SourceCore
<Tuple<IList<T1>, IList<T2>, IList<T3>>>(
Blocks\BufferBlock.cs (1)
65
_source = new
SourceCore
<T>(this, dataflowBlockOptions,
Blocks\JoinBlock.cs (2)
65
_source = new
SourceCore
<Tuple<T1, T2>>(this, dataflowBlockOptions,
292
_source = new
SourceCore
<Tuple<T1, T2, T3>>(this, dataflowBlockOptions,
Blocks\TransformBlock.cs (1)
112
_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;
196
private readonly
SourceCore
<T[]>.DebuggingInformation _sourceDebuggingInformation;
Blocks\BatchedJoinBlock.cs (4)
40
private readonly
SourceCore
<Tuple<IList<T1>, IList<T2>>> _source;
224
private readonly
SourceCore
<Tuple<IList<T1>, IList<T2>>>.DebuggingInformation _sourceDebuggingInformation;
288
private readonly
SourceCore
<Tuple<IList<T1>, IList<T2>, IList<T3>>> _source;
482
private readonly
SourceCore
<Tuple<IList<T1>, IList<T2>, IList<T3>>>.DebuggingInformation _sourceDebuggingInformation;
Blocks\BroadcastBlock.cs (1)
495
/// <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;
442
private readonly
SourceCore
<T>.DebuggingInformation _sourceDebuggingInformation;
Blocks\JoinBlock.cs (4)
36
private readonly
SourceCore
<Tuple<T1, T2>> _source;
205
private readonly
SourceCore
<Tuple<T1, T2>>.DebuggingInformation _sourceDebuggingInformation;
261
private readonly
SourceCore
<Tuple<T1, T2, T3>> _source;
435
private readonly
SourceCore
<Tuple<T1, T2, T3>>.DebuggingInformation _sourceDebuggingInformation;
Blocks\TransformBlock.cs (4)
32
private readonly
SourceCore
<TOutput> _source;
145
var
sourceCore = (
SourceCore
<TOutput>)state!;
417
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!;
623
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>
521
var
thisSourceCore = (
SourceCore
<TOutput>)state!;
759
_taskForOutputProcessing = new Task(static thisSourceCore => ((
SourceCore
<TOutput>)thisSourceCore!).OfferMessagesLoopCore(), this,
784
var
thisSourceCore = (
SourceCore
<TOutput>)state!;
925
Task.Factory.StartNew(static state => ((
SourceCore
<TOutput>)state!).CompleteBlockOncePossible(),
1000
private readonly
SourceCore
<TOutput> _source;
1004
internal DebuggingInformation(
SourceCore
<TOutput> source) { _source = source; }