1 write to _source
System.Threading.Tasks.Dataflow (1)
17 references to _source
System.Threading.Tasks.Dataflow (17)
Blocks\JoinBlock.cs (17)
290() => _source.AddMessage(Tuple.Create(_target1!.GetOneMessage(), _target2!.GetOneMessage(), _target3!.GetOneMessage())),
294_source.AddException(exception);
304_ => _source.Complete(),
311_source.Completion.ContinueWith(static (completed, state) =>
320dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((JoinBlock<T1, T2, T3>)state!)._sharedResources.CompleteEachTarget(), this);
331return _source.LinkTo(target, linkOptions);
337return _source.TryReceive(filter, out item);
341public bool TryReceiveAll([NotNullWhen(true)] out IList<Tuple<T1, T2, T3>>? items) { return _source.TryReceiveAll(out items); }
344public int OutputCount { get { return _source.OutputCount; } }
347public Task Completion { get { return _source.Completion; } }
389return _source.ConsumeMessage(messageHeader, target, out messageConsumed);
395return _source.ReserveMessage(messageHeader, target);
401_source.ReleaseReservation(messageHeader, target);
405private int OutputCountForDebugger { get { return _source.GetDebuggingInformation().OutputCount; } }
408public override string ToString() { return Common.GetNameForDebugger(this, _source.DataflowBlockOptions); }
412$"{Common.GetNameForDebugger(this, _source.DataflowBlockOptions)} OutputCount = {OutputCountForDebugger}";
431_sourceDebuggingInformation = joinBlock._source.GetDebuggingInformation();