1 write to _source
System.Threading.Tasks.Dataflow (1)
Blocks\TransformBlock.cs (1)
112
_source
= new SourceCore<TOutput>(this, dataflowBlockOptions,
20 references to _source
System.Threading.Tasks.Dataflow (20)
Blocks\TransformBlock.cs (20)
42
private object ParallelSourceLock { get { return
_source
; } }
120
_reorderingBuffer = new ReorderingBuffer<TOutput>(this, static (owningSource, message) => ((TransformBlock<TInput, TOutput>)owningSource).
_source
.AddMessage(message));
148
},
_source
, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default);
154
_source
.Completion.ContinueWith(static (completed, state) =>
208
_source
.AddMessage(outputItem!);
214
_source
.AddMessage(outputItem!);
312
_source
.AddMessage(outputItem!);
318
_source
.AddMessage(outputItem!);
349
return
_source
.LinkTo(target, linkOptions);
355
return
_source
.TryReceive(filter, out item);
359
public bool TryReceiveAll([NotNullWhen(true)] out IList<TOutput>? items) { return
_source
.TryReceiveAll(out items); }
362
public Task Completion { get { return
_source
.Completion; } }
368
public int OutputCount { get { return
_source
.OutputCount; } }
379
return
_source
.ConsumeMessage(messageHeader, target, out messageConsumed);
385
return
_source
.ReserveMessage(messageHeader, target);
391
_source
.ReleaseReservation(messageHeader, target);
397
private int OutputCountForDebugger { get { return
_source
.GetDebuggingInformation().OutputCount; } }
400
public override string ToString() { return Common.GetNameForDebugger(this,
_source
.DataflowBlockOptions); }
404
$"{Common.GetNameForDebugger(this,
_source
.DataflowBlockOptions)}, InputCount = {InputCountForDebugger}, OutputCount = {OutputCountForDebugger}";
426
_sourceDebuggingInformation = transformBlock.
_source
.GetDebuggingInformation();