protected void forEachHeader()

in src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java [55:57]

• 3 lines of code
• 1 McCabe index (conditional complexity)

    protected void forEachHeader(BiConsumer<String, String> fn) {
        this.headers.forEach((k, v) -> fn.accept(k, v));
    }