1 write to _source
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
318
_source
= new SourceCore<Tuple<IList<T1>, IList<T2>, IList<T3>>>(
19 references to _source
System.Threading.Tasks.Dataflow (19)
Blocks\BatchedJoinBlock.cs (19)
328
_source
.AddMessage(Tuple.Create(_target1.GetAndEmptyMessages(), _target2!.GetAndEmptyMessages(), _target3!.GetAndEmptyMessages()));
339
_source
.Complete();
341
_source
.AddException,
351
_source
.Completion.ContinueWith(static (completed, state) =>
360
dataflowBlockOptions.CancellationToken,
_source
.Completion, static (state, _) => ((BatchedJoinBlock<T1, T2, T3>)state!).CompleteEachTarget(), this);
383
return
_source
.LinkTo(target, linkOptions);
389
return
_source
.TryReceive(filter, out item);
393
public bool TryReceiveAll([NotNullWhen(true)] out IList<Tuple<IList<T1>, IList<T2>, IList<T3>>>? items) { return
_source
.TryReceiveAll(out items); }
396
public int OutputCount { get { return
_source
.OutputCount; } }
399
public Task Completion { get { return
_source
.Completion; } }
423
Debug.Assert(
_source
!= null, "_source not initialized");
427
if (!_sharedResources._decliningPermanently)
_source
.AddException(exception);
436
return
_source
.ConsumeMessage(messageHeader, target, out messageConsumed);
443
return
_source
.ReserveMessage(messageHeader, target);
450
_source
.ReleaseReservation(messageHeader, target);
464
private int OutputCountForDebugger { get { return
_source
.GetDebuggingInformation().OutputCount; } }
467
public override string ToString() { return Common.GetNameForDebugger(this,
_source
.DataflowBlockOptions); }
471
$"{Common.GetNameForDebugger(this,
_source
.DataflowBlockOptions)}, BatchSize = {BatchSize}, OutputCount = {OutputCountForDebugger}";
489
_sourceDebuggingInformation = batchedJoinBlock.
_source
.GetDebuggingInformation();