validateSubscribePayload() — netty Function Reference

Architecture documentation for the validateSubscribePayload() function in MqttTestUtils.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ validateSubscribePayload() — netty Function Reference

Dependency Diagram

graph TD
  c891d9b3_3587_69b9_a927_506ace3b44bc["validateSubscribePayload()"]
  492c27ee_b1b3_752e_cd75_4675bc98321c["MqttTestUtils"]
  c891d9b3_3587_69b9_a927_506ace3b44bc -->|defined in| 492c27ee_b1b3_752e_cd75_4675bc98321c
  338fde2b_c14e_9ff6_b49a_4aa747c97084["validateTopicSubscription()"]
  c891d9b3_3587_69b9_a927_506ace3b44bc -->|calls| 338fde2b_c14e_9ff6_b49a_4aa747c97084
  style c891d9b3_3587_69b9_a927_506ace3b44bc fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/test/java/io/netty/handler/codec/mqtt/MqttTestUtils.java lines 163–174

    public static void validateSubscribePayload(MqttSubscribePayload expected, MqttSubscribePayload actual) {
        List<MqttTopicSubscription> expectedTopicSubscriptions = expected.topicSubscriptions();
        List<MqttTopicSubscription> actualTopicSubscriptions = actual.topicSubscriptions();

        assertEquals(
                expectedTopicSubscriptions.size(),
                actualTopicSubscriptions.size(),
                "MqttSubscribePayload TopicSubscriptionList size mismatch");
        for (int i = 0; i < expectedTopicSubscriptions.size(); i++) {
            validateTopicSubscription(expectedTopicSubscriptions.get(i), actualTopicSubscriptions.get(i));
        }
    }