11 references to WriteOnceBlock
System.Threading.Tasks.Dataflow (11)
Blocks\BroadcastBlock.cs (1)
30
/// <see cref="
WriteOnceBlock
{T}"/>, that element will be overwritten as new elements are provided
Blocks\WriteOnceBlock.cs (10)
24
[DebuggerTypeProxy(typeof(
WriteOnceBlock
<>.DebugView))]
47
/// <summary>Initializes the <see cref="
WriteOnceBlock
{T}"/>.</summary>
56
/// <summary>Initializes the <see cref="
WriteOnceBlock
{T}"/> with the specified <see cref="DataflowBlockOptions"/>.</summary>
61
/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="
WriteOnceBlock
{T}"/>.</param>
98
dataflowBlockOptions.CancellationToken, _lazyCompletionTaskSource.Task, static (state, _) => ((
WriteOnceBlock
<T>)state!).Complete(), this);
123
var taskForOutputProcessing = new Task(static state => ((
WriteOnceBlock
<T>)state!).OfferToTargetsAndCompleteBlock(), this,
142
Tuple<
WriteOnceBlock
<T>, IList<Exception>> blockAndList = (Tuple<
WriteOnceBlock
<T>, IList<Exception>>)state!;
528
private readonly
WriteOnceBlock
<T> _writeOnceBlock;
532
public DebugView(
WriteOnceBlock
<T> writeOnceBlock)