digital-garden/knowledge/dev/java/frameworks/quarkus/Выполнение блокирующего кода в реактивном потоке.md

aliases	tags	date	zero-link	parents	linked
	зрелость/🌱	2023-11-22	00 Java разработка	Quarkus

Uni<String> uni = Uni.createFrom()
        .item(this::invokeRemoteServiceUsingBlockingIO)
        .runSubscriptionOn(Infrastructure.getDefaultWorkerPool());

Multi<String> multi = Multi.createFrom().items("john", "jack", "sue")
        .emitOn(Infrastructure.getDefaultWorkerPool())
        .onItem().transform(this::invokeRemoteServiceUsingBlockingIO);