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)
51Assert.Equal(2, renderer._unacknowledgedRenderBatches.Count); 75Assert.Equal(10, renderer._unacknowledgedRenderBatches.Count); 100Assert.Equal(9, renderer._unacknowledgedRenderBatches.Count); 120Assert.Equal(10, renderer._unacknowledgedRenderBatches.Count); 125Assert.Equal(10, renderer._unacknowledgedRenderBatches.Count); 231var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 294var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 357var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 373Assert.Empty(renderer._unacknowledgedRenderBatches); 414var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 500Assert.Single(renderer._unacknowledgedRenderBatches); 560Assert.Equal(2, renderer._unacknowledgedRenderBatches.Count); // Initial render, re-render 579Assert.Single(renderer._unacknowledgedRenderBatches); 599Assert.Equal(3, renderer._unacknowledgedRenderBatches.Count); // Initial render, dispose, and re-initialize 634Assert.Equal(2, renderer._unacknowledgedRenderBatches.Count); // Initial render, dispose