@Override
    protected Mono<Void> start() {
        eventToListener = new ConcurrentHashMap<>(8);
        LiveKitProperties properties = loadProperties(LiveKitProperties.class);
        liveKitClient = new LiveKitClient(properties, webhookEvent -> {
            Consumer consumer = eventToListener.get(webhookEvent.getEvent());
            if (consumer != null) {
                consumer.accept(webhookEvent);
            }
        });
        return liveKitClient.start();
    }
The class is an bridge between Turms and LiveKit.

@author James Chen
turms-plugins/turms-plugin-livekit/src/main/java/im/turms/plugin/livekit/LiveKitConferenceServiceProvider.java