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> 95dataflowBlockOptions.CancellationToken, _lazyCompletionTaskSource.Task, static (state, _) => ((WriteOnceBlock<T>)state!).Complete(), this); 120var taskForOutputProcessing = new Task(static state => ((WriteOnceBlock<T>)state!).OfferToTargetsAndCompleteBlock(), this, 139Tuple<WriteOnceBlock<T>, IList<Exception>> blockAndList = (Tuple<WriteOnceBlock<T>, IList<Exception>>)state!; 516private readonly WriteOnceBlock<T> _writeOnceBlock; 520public DebugView(WriteOnceBlock<T> writeOnceBlock)