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) => 360dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchedJoinBlock<T1, T2, T3>)state!).CompleteEachTarget(), this); 383return _source.LinkTo(target, linkOptions); 389return _source.TryReceive(filter, out item); 393public bool TryReceiveAll([NotNullWhen(true)] out IList<Tuple<IList<T1>, IList<T2>, IList<T3>>>? items) { return _source.TryReceiveAll(out items); } 396public int OutputCount { get { return _source.OutputCount; } } 399public Task Completion { get { return _source.Completion; } } 423Debug.Assert(_source != null, "_source not initialized"); 427if (!_sharedResources._decliningPermanently) _source.AddException(exception); 436return _source.ConsumeMessage(messageHeader, target, out messageConsumed); 443return _source.ReserveMessage(messageHeader, target); 450_source.ReleaseReservation(messageHeader, target); 464private int OutputCountForDebugger { get { return _source.GetDebuggingInformation().OutputCount; } } 467public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); } 471$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)}, BatchSize = {BatchSize}, OutputCount = {OutputCountForDebugger}"; 489_sourceDebuggingInformation = batchedJoinBlock._source.GetDebuggingInformation();