2 references to _channel
Aspire.Confluent.Kafka (2)
MetricsChannel.cs (2)
23
public ChannelReader<string> Reader =>
_channel
.Reader;
24
public ChannelWriter<string> Writer =>
_channel
.Writer;