Avoid wrapping scheduled executors
This is part of a larger bug fix in Quarkus, see
@@ -77,7 +77,7 @@ public class Infrastructure {
DEFAULT_SCHEDULER.shutdownNow();
}
DEFAULT_EXECUTOR = s;
- DEFAULT_SCHEDULER = new MutinyScheduler(s);
+ DEFAULT_SCHEDULER = (s instanceof ScheduledExecutorService) ? (ScheduledExecutorService) s : new MutinyScheduler(s);
}
public static ScheduledExecutorService getDefaultWorkerPool() {
@@ -361,7 +361,7 @@ public class Infrastructure {
/**
* Log from an operator.
- *
+ * <p>
* This method should never be called directly but only from {@link Multi#log(String)} and {@link Uni#log(String)}.
*
* @param identifier the event identifier
