Function topic_stats_test

nodedb/src/control/pubsub.rs:429–438

()

    #[test]
    fn topic_stats_test() {
        let registry = TopicRegistry::new(1000);
        registry.create_topic("stats").unwrap();
        registry.publish("stats", "a".into(), "admin").unwrap();
        registry.publish("stats", "b".into(), "admin").unwrap();

        let stats = registry.topic_stats("stats").unwrap();
        assert_eq!(stats.message_count, 2);
        assert_eq!(stats.next_seq, 3);
    }

    #[tokio::test]
    async fn consumer_group_round_robin() {