Function consumer_group_stats

nodedb/src/control/pubsub.rs:474–483

()

    #[test]
    fn consumer_group_stats() {
        let registry = TopicRegistry::new(1000);
        registry.create_topic("cg").unwrap();
        registry.subscribe_group("cg", "g1", 0).unwrap();
        registry.subscribe_group("cg", "g1", 0).unwrap();
        registry.subscribe_group("cg", "g2", 0).unwrap();

        let stats = registry.topic_stats("cg").unwrap();
        assert_eq!(stats.consumer_group_count, 2);
    }
}