9 references to JoinBlock
System.Threading.Tasks.Dataflow (9)
Blocks\JoinBlock.cs (9)
249[DebuggerTypeProxy(typeof(JoinBlock<,,>.DebugView))]
263/// <summary>Initializes the <see cref="JoinBlock{T1,T2,T3}"/>.</summary>
268/// <summary>Initializes the <see cref="JoinBlock{T1,T2,T3}"/>.</summary>
280if (dataflowBlockOptions.BoundedCapacity > 0) onItemsRemoved = static (owningSource, count) => ((JoinBlock<T1, T2, T3>)owningSource)._sharedResources.OnItemsRemoved(count);
284static owningSource => ((JoinBlock<T1, T2, T3>)owningSource)._sharedResources.CompleteEachTarget(),
313var thisBlock = ((JoinBlock<T1, T2, T3>)state!) as IDataflowBlock;
320dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((JoinBlock<T1, T2, T3>)state!)._sharedResources.CompleteEachTarget(), this);
421private readonly JoinBlock<T1, T2, T3> _joinBlock;
427public DebugView(JoinBlock<T1, T2, T3> joinBlock)