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

21 lines
560 B
Markdown
Raw Normal View History

2024-06-13 21:01:37 +03:00
---
aliases:
tags:
- зрелость/🌱
date:
- - 2023-11-22
zero-link:
2024-09-01 20:49:54 +03:00
- "[[../../../../../garden/ru/meta/zero/00 Java разработка]]"
2024-06-13 21:01:37 +03:00
parents:
- "[[Quarkus]]"
linked:
---
```java
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);
```