public List getSubjects()

in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java [417:430]

• 14 lines of code
• 4 McCabe index (conditional complexity)

    public List<String> getSubjects(StorageServiceContext context, String tenant) {
        List<String> subjects = new ArrayList<>();
        RocksIterator iterator = cache.newIterator(subjectCfHandle());
        for (iterator.seekToFirst(); iterator.isValid(); iterator.next()) {
            String subjectFullName = new String(iterator.key());
            String[] subjectFromCache = subjectFullName.split(String.valueOf(SchemaConstants.SUBJECT_SEPARATOR));
            String tenantFromKey = subjectFromCache[1];
            String subjectFromKey = subjectFromCache[2];
            if (isSuperAdmin(context.getUserName()) || tenant.equals(tenantFromKey)) {
                subjects.add(subjectFromKey);
            }
        }
        return subjects;
    }