2 references to Reader
Aspire.Confluent.Kafka (2)
MetricsService.cs (2)
19
while (await channel.
Reader
.WaitToReadAsync(stoppingToken).ConfigureAwait(false))
21
while (channel.
Reader
.TryRead(out var json))