void registerStreamCachingClasses()

in camel-k-core/deployment/src/main/java/org/apache/camel/k/core/quarkus/deployment/CoreProcessor.java [75:96]

17 lines of code
1 McCabe index (conditional complexity)


    void registerStreamCachingClasses(
            BuildProducer<ReflectiveClassBuildItem> reflectiveClass,
            CombinedIndexBuildItem combinedIndex) {

        final IndexView view = combinedIndex.getIndex();

        getAllKnownImplementors(view, StreamCachingStrategy.class)
            .forEach(i-> reflectiveClass.produce(reflectiveClassBuildItem(i)));

        getAllKnownImplementors(view, StreamCachingStrategy.Statistics.class)
            .forEach(i-> reflectiveClass.produce(reflectiveClassBuildItem(i)));

        getAllKnownImplementors(view, StreamCachingStrategy.SpoolRule.class)
            .forEach(i-> reflectiveClass.produce(reflectiveClassBuildItem(i)));

        reflectiveClass.produce(
            new ReflectiveClassBuildItem(
                true,
                false,
                StreamCachingStrategy.SpoolRule.class)
        );
    }