1 write to Rx
Aspire.Confluent.Kafka (1)
StatisticsJsonSerializerContext.Statistics.g.cs (1)
303
Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).
Rx
= value!,
5 references to Rx
Aspire.Confluent.Kafka (5)
MetricsService.cs (3)
58
metrics.Rx.Add(statistics.
Rx
- previous.
Rx
, tags);
69
metrics.Rx.Add(statistics.
Rx
, tags);
StatisticsJsonSerializerContext.Statistics.g.cs (2)
302
Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).
Rx
,
475
writer.WriteNumber(PropName_rx, ((global::Aspire.Confluent.Kafka.Statistics)value).
Rx
);