quarkus 3 中没有stream()方法

Question

我想将我的代码从 quarkus 2 迁移到 quarkus 3。我的所有代码都是响应式的。我发现了一些stream()方法的问题，这些问题在quarkus 3中被删除了。

来自 quarkus 2 的示例代码。Fruit 是存储在 PG 数据库中的实体。

return Fruit.streamAll();

如何在 quarkus 3 中获得相同的结果？我更喜欢

Multi<Fruit>

而不是

Uni<List<Fruit>>

。

Answer 1

我的解决方案是

Multi<Fruit> fruits = Fruit.listAll()
  .onItem()
  .transformToMulti(list -> Multi.createForm().iterable(list));

无论如何，我更喜欢 quarkus 2

Fruit.streamAll()

解决方案。