public void entryRemoved()

in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/handler/SchemaHandler.java [259:272]

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

        public void entryRemoved(EntryEvent<String, SchemaInfo> current) {
            if (current == null || current.getValue() == null || current.getValue().getDetails() == null) {
                return;
            }
            // Delete subjects bind to any version
            List<SchemaRecordInfo> allSchemaRecords = current.getValue().getDetails().getSchemaRecords();
            List<String> allSubjects = allSchemaRecords.parallelStream()
                    .flatMap(record -> record.getSubjects().stream().map(SubjectInfo::fullName))
                    .collect(Collectors.toList());

            allSubjects.forEach(subject -> {
                subjectCache.remove(subject);
            });
        }