in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/PulsarReactiveClientModule.java [136:158]
public void serialize(Scheduler scheduler, JsonGenerator gen, SerializerProvider serializers)
throws IOException {
switch (scheduler.getClass().getName()) {
case "reactor.core.scheduler.BoundedElasticScheduler":
gen.writeString("boundedElastic");
break;
case "reactor.core.scheduler.ParallelScheduler":
gen.writeString("parallel");
break;
case "reactor.core.scheduler.SingleScheduler":
gen.writeString("single");
break;
case "reactor.core.scheduler.ImmediateScheduler":
gen.writeString("immediate");
break;
case "reactor.core.scheduler.Schedulers$CachedScheduler":
gen.writeString(scheduler.toString()
.substring("Schedulers.".length(), scheduler.toString().length() - "()".length()));
break;
default:
gen.writeString(scheduler.getClass().getName());
}
}