From 1edbe6386bb0c22c39ec6c81d94f19cd7ac21751 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Wed, 16 Nov 2022 19:29:18 -0500 Subject: [PATCH] Add native hints for Flux --- .../org/springframework/pulsar/aot/PulsarRuntimeHints.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/aot/PulsarRuntimeHints.java b/spring-pulsar/src/main/java/org/springframework/pulsar/aot/PulsarRuntimeHints.java index b569228c..828722fb 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/aot/PulsarRuntimeHints.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/aot/PulsarRuntimeHints.java @@ -41,6 +41,8 @@ import org.springframework.aot.hint.RuntimeHintsRegistrar; import org.springframework.aot.hint.TypeReference; import org.springframework.lang.Nullable; +import reactor.core.publisher.Flux; + /** * {@link RuntimeHintsRegistrar} for Spring for Apache Pulsar. * @@ -59,7 +61,7 @@ public class PulsarRuntimeHints implements RuntimeHintsRegistrar { Stream.of(HashSet.class, TreeMap.class, Authentication.class, AuthenticationDataProvider.class, SecretsSerializer.class, NioSocketChannel.class, AbstractByteBufAllocator.class, NioDatagramChannel.class, PulsarAdminBuilderImpl.class, OffloadProcessStatusImpl.class, Commands.class, - ReferenceCountUtil.class).forEach( + ReferenceCountUtil.class, Flux.class).forEach( type -> reflectionHints.registerType(type, builder -> builder.withMembers(MemberCategory.INVOKE_DECLARED_CONSTRUCTORS, MemberCategory.INVOKE_DECLARED_METHODS,