25 references to WaitForMeasurementsAsync
Aspire.Confluent.Kafka.Tests (16)
Aspire8MetricsTests.cs (16)
64collectorNetworkTx.WaitForMeasurementsAsync(statistics.Count), 65collectorNetworkTransmitted.WaitForMeasurementsAsync(statistics.Count), 66collectorNetworkRx.WaitForMeasurementsAsync(statistics.Count), 67collectorNetworkReceived.WaitForMeasurementsAsync(statistics.Count), 68collectorMessageTx.WaitForMeasurementsAsync(statistics.Count), 69collectorMessageTransmitted.WaitForMeasurementsAsync(statistics.Count), 70collectorMessageRx.WaitForMeasurementsAsync(statistics.Count), 71collectorMessageReceived.WaitForMeasurementsAsync(statistics.Count) 179collectorNetworkTx.WaitForMeasurementsAsync(statistics.Count), 180collectorNetworkTransmitted.WaitForMeasurementsAsync(statistics.Count), 181collectorNetworkRx.WaitForMeasurementsAsync(statistics.Count), 182collectorNetworkReceived.WaitForMeasurementsAsync(statistics.Count), 183collectorMessageTx.WaitForMeasurementsAsync(statistics.Count), 184collectorMessageTransmitted.WaitForMeasurementsAsync(statistics.Count), 185collectorMessageRx.WaitForMeasurementsAsync(statistics.Count), 186collectorMessageReceived.WaitForMeasurementsAsync(statistics.Count)
Microsoft.Extensions.Diagnostics.Testing (1)
Metrics\MetricCollector.cs (1)
258await WaitForMeasurementsAsync(minCount, cancellationTokenSource.Token).ConfigureAwait(false);
Microsoft.Extensions.Diagnostics.Testing.Tests (8)
Metrics\MetricCollectorTests.cs (8)
245await Assert.ThrowsAsync<ArgumentOutOfRangeException>(async () => await collector.WaitForMeasurementsAsync(-1)); 246await Assert.ThrowsAsync<ArgumentOutOfRangeException>(async () => await collector.WaitForMeasurementsAsync(0)); 250var wait = collector.WaitForMeasurementsAsync(2); 265wait = collector.WaitForMeasurementsAsync(1); 284var wait = collector.WaitForMeasurementsAsync(1, cts.Token); 309await Assert.ThrowsAsync<ArgumentOutOfRangeException>(async () => await collector.WaitForMeasurementsAsync(-1)); 310await Assert.ThrowsAsync<ArgumentOutOfRangeException>(async () => await collector.WaitForMeasurementsAsync(0)); 366await Assert.ThrowsAsync<ObjectDisposedException>(async () => await collector.WaitForMeasurementsAsync(1));