9 references to JoinBlock
System.Threading.Tasks.Dataflow (9)
Blocks\JoinBlock.cs (9)
255[DebuggerTypeProxy(typeof(JoinBlock<,,>.DebugView))]
269/// <summary>Initializes the <see cref="JoinBlock{T1,T2,T3}"/>.</summary>
274/// <summary>Initializes the <see cref="JoinBlock{T1,T2,T3}"/>.</summary>
289if (dataflowBlockOptions.BoundedCapacity > 0) onItemsRemoved = static (owningSource, count) => ((JoinBlock<T1, T2, T3>)owningSource)._sharedResources.OnItemsRemoved(count);
293static owningSource => ((JoinBlock<T1, T2, T3>)owningSource)._sharedResources.CompleteEachTarget(),
322var thisBlock = ((JoinBlock<T1, T2, T3>)state!) as IDataflowBlock;
329dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((JoinBlock<T1, T2, T3>)state!)._sharedResources.CompleteEachTarget(), this);
433private readonly JoinBlock<T1, T2, T3> _joinBlock;
439public DebugView(JoinBlock<T1, T2, T3> joinBlock)