12 references to JoinBlock
System.Threading.Tasks.Dataflow (12)
Base\DataflowBlockOptions.cs (1)
333
/// group together multiple messages, blocks such as <see cref="
JoinBlock
{T1,T2}"/> and
Blocks\JoinBlock.cs (11)
30
[DebuggerTypeProxy(typeof(
JoinBlock
<,>.DebugView))]
42
/// <summary>Initializes the <see cref="
JoinBlock
{T1,T2}"/>.</summary>
47
/// <summary>Initializes the <see cref="
JoinBlock
{T1,T2}"/>.</summary>
48
/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="
JoinBlock
{T1,T2}"/>.</param>
62
if (dataflowBlockOptions.BoundedCapacity > 0) onItemsRemoved = static (owningSource, count) => ((
JoinBlock
<T1, T2>)owningSource)._sharedResources.OnItemsRemoved(count);
66
static owningSource => ((
JoinBlock
<T1, T2>)owningSource)._sharedResources.CompleteEachTarget(),
97
var thisBlock = ((
JoinBlock
<T1, T2>)state!) as IDataflowBlock;
104
dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((
JoinBlock
<T1, T2>)state!)._sharedResources.CompleteEachTarget(), this);
203
private readonly
JoinBlock
<T1, T2> _joinBlock;
209
public DebugView(
JoinBlock
<T1, T2> joinBlock)
275
/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="
JoinBlock
{T1,T2}"/>.</param>