15 references to BroadcastBlock
System.Threading.Tasks.Dataflow (15)
Blocks\BroadcastBlock.cs (15)
29
/// <see cref="
BroadcastBlock
{T}"/> exposes at most one element at a time. However, unlike
31
/// to the block. <see cref="
BroadcastBlock
{T}"/> ensures that the current element is broadcast to any
35
[DebuggerTypeProxy(typeof(
BroadcastBlock
<>.DebugView))]
49
/// <summary>Initializes the <see cref="
BroadcastBlock
{T}"/> with the specified cloning function.</summary>
58
/// <summary>Initializes the <see cref="
BroadcastBlock
{T}"/> with the specified cloning function and <see cref="DataflowBlockOptions"/>.</summary>
63
/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="
BroadcastBlock
{T}"/>.</param>
90
var thisBlock = ((
BroadcastBlock
<T>)state!) as IDataflowBlock;
97
dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((
BroadcastBlock
<T>)state!).Complete(), this);
254
new Task(static state => ((
BroadcastBlock
<T>)state!).ConsumeMessagesLoopCore(), this,
384
var
thisBroadcastBlock = (
BroadcastBlock
<T>)state!;
450
private readonly
BroadcastBlock
<T> _broadcastBlock;
456
public DebugView(
BroadcastBlock
<T> broadcastBlock)
511
private readonly
BroadcastBlock
<TOutput> _owningSource;
542
BroadcastBlock
<TOutput> owningSource,