22 references to _unacknowledgedRenderBatches
Microsoft.AspNetCore.Components.Server (7)
Circuits\RemoteRenderer.cs (7)
89if (_unacknowledgedRenderBatches.Count >= _options.MaxBufferedUnacknowledgedRenderBatches) 137while (_unacknowledgedRenderBatches.TryDequeue(out var entry)) 179_unacknowledgedRenderBatches.Enqueue(pendingRender); 200return Task.WhenAll(_unacknowledgedRenderBatches.Select(WriteBatchBytesAsync)); 267if (!_unacknowledgedRenderBatches.TryPeek(out var nextUnacknowledgedBatch) || incomingBatchId < nextUnacknowledgedBatch.BatchId) 276while (_unacknowledgedRenderBatches.TryPeek(out nextUnacknowledgedBatch) && nextUnacknowledgedBatch.BatchId <= incomingBatchId) 281_unacknowledgedRenderBatches.TryDequeue(out _);
Microsoft.AspNetCore.Components.Server.Tests (15)
Circuits\RemoteRendererTest.cs (15)
47Assert.Equal(2, renderer._unacknowledgedRenderBatches.Count); 71Assert.Equal(10, renderer._unacknowledgedRenderBatches.Count); 96Assert.Equal(9, renderer._unacknowledgedRenderBatches.Count); 116Assert.Equal(10, renderer._unacknowledgedRenderBatches.Count); 121Assert.Equal(10, renderer._unacknowledgedRenderBatches.Count); 230var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 293var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 356var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 372Assert.Empty(renderer._unacknowledgedRenderBatches); 413var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 499Assert.Single(renderer._unacknowledgedRenderBatches); 559Assert.Equal(2, renderer._unacknowledgedRenderBatches.Count); // Initial render, re-render 578Assert.Single(renderer._unacknowledgedRenderBatches); 598Assert.Equal(3, renderer._unacknowledgedRenderBatches.Count); // Initial render, dispose, and re-initialize 633Assert.Equal(2, renderer._unacknowledgedRenderBatches.Count); // Initial render, dispose