quarkus-keycloak-admin-client扩展的反应式版本？

import io.smallrye.reactive.messaging.annotations.Channel;
import io.smallrye.reactive.messaging.annotations.Emitter;
import io.smallrye.mutiny.Uni;
import org.eclipse.microprofile.reactive.messaging.Incoming;
import org.keycloak.admin.client.Keycloak;
import org.keycloak.admin.client.KeycloakBuilder;
import org.keycloak.admin.client.resource.RealmResource;
import org.keycloak.admin.client.resource.UserResource;
import org.keycloak.representations.idm.UserRepresentation;

@ApplicationScoped
public class KeycloakService {

    private final Keycloak keycloak;

    public KeycloakService() {
        this.keycloak = KeycloakBuilder.builder()
                .serverUrl("http://localhost:8080/auth")
                .realm("myrealm")
                .clientId("myclient")
                .clientSecret("myclientsecret")
                .build();
    }

    public Uni<UserRepresentation> findUserByUsername(String username) {
        RealmResource realm = keycloak.realm("myrealm");
        return Uni.createFrom().item(realm)
                .emitOn(Dispatchers.IO)
                .onItem().transformToUni(realm -> realm.users().search(username).firstResult());
    }

    @Incoming("user-updates")
    @Outgoing("user-updates-processed")
    public Uni<Void> processUserUpdate(UserRepresentation user) {
        return findUserByUsername(user.getUsername())
                .onItem().invoke(userResource -> userResource.get())
                .onItem().transform(userRepresentation -> {
                    userRepresentation.setEmail(user.getEmail());
                    return userResource.update(userRepresentation);
                })
                .then();
    }
}