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>
93
var thisBlock = ((
BroadcastBlock
<T>)state!) as IDataflowBlock;
100
dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((
BroadcastBlock
<T>)state!).Complete(), this);
260
new Task(static state => ((
BroadcastBlock
<T>)state!).ConsumeMessagesLoopCore(), this,
390
var
thisBroadcastBlock = (
BroadcastBlock
<T>)state!;
456
private readonly
BroadcastBlock
<T> _broadcastBlock;
462
public DebugView(
BroadcastBlock
<T> broadcastBlock)
517
private readonly
BroadcastBlock
<TOutput> _owningSource;
548
BroadcastBlock
<TOutput> owningSource,