@GET
@Path("/p1")
public Uni p1() {
Log.info("Entry (event loop)");
return Uni.createFrom()
.item("input")
.onItem().transform(input -> {
Log.info("Light transform");
return input.toUpperCase();
})
.emitOn(Infrastructure.getDefaultWorkerPool()) // ← Switch to worker
.onItem().transform(data -> {
Log.info("Heavy work (worker)");
try {
Thread.sleep(1000);
} catch (InterruptedException ignored) {
}
return "Processed: " + data;
})
.emitOn(Infrastructure.getDefaultExecutor()) // doesn't work
.onItem().transform(result -> {
Log.info("Back on event loop");
return Response.ok(result).build();
});
}
< /code>
2025-08-11 04:13:58,404 INFO [com.exa.ExampleResource] (vert.x-eventloop-thread-1) Entry (event loop)
2025-08-11 04:13:58,405 INFO [com.exa.ExampleResource] (vert.x-eventloop-thread-1) Light transform
2025-08-11 04:13:58,405 INFO [com.exa.ExampleResource] (executor-thread-1) Heavy work (worker)
2025-08-11 04:13:59,407 INFO [com.exa.ExampleResource] (executor-thread-1) Back on event loop< /code>
Я не могу переключиться обратно в поток цикла событий, используя
emitOn(Infrastructure.getDefaultExecutor())< /code>.
Что я делаю не так?>
Подробнее здесь: https://stackoverflow.com/questions/797 ... to-executo
