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)
52Assert.Equal(2, renderer._unacknowledgedRenderBatches.Count); 76Assert.Equal(10, renderer._unacknowledgedRenderBatches.Count); 101Assert.Equal(9, renderer._unacknowledgedRenderBatches.Count); 121Assert.Equal(10, renderer._unacknowledgedRenderBatches.Count); 126Assert.Equal(10, renderer._unacknowledgedRenderBatches.Count); 233var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 296var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 359var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 375Assert.Empty(renderer._unacknowledgedRenderBatches); 416var originallyQueuedBatches = renderer._unacknowledgedRenderBatches.Count; 502Assert.Single(renderer._unacknowledgedRenderBatches); 562Assert.Equal(2, renderer._unacknowledgedRenderBatches.Count); // Initial render, re-render 581Assert.Single(renderer._unacknowledgedRenderBatches); 601Assert.Equal(3, renderer._unacknowledgedRenderBatches.Count); // Initial render, dispose, and re-initialize 636Assert.Equal(2, renderer._unacknowledgedRenderBatches.Count); // Initial render, dispose