Add native hints for Flux

This commit is contained in:
Soby Chacko
2022-11-16 19:29:18 -05:00
parent fb3973785f
commit 1edbe6386b

View File

@@ -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,