如何将返回列表的方法转换为反应流smallrye mutiny？

Question

我对反应式编程非常陌生，希望转换一个返回<代码>列表的方法

我尝试创建Publisher等，但找不到合适的示例来进一步进行。有人能提供一些指导或建议吗？

正如下面的代码所提供的，我有一个方法可以提供随机字符串列表。在这里，我需要等到所有元素都被添加到List后才能返回。我想实现反应式流方法，而不是等待所有元素被添加到列表中，我希望在生成后立即返回它。

我相信使用SmallRye Mutiny可以实现这一点，您能让我知道如何实现吗？

import org.apache.commons.lang.RandomStringUtils;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) {
        System.out.println(addElements(5));
    }

    private static List<String> addElements(final int elementsCount) {
        final List<String> returnList = new ArrayList<>();
        IntStream.range(0, elementsCount).forEach(count -> {
            returnList.add(RandomStringUtils.randomAlphanumeric(17).toUpperCase());
        });
        return returnList;
    }
}

Answer 1

有一种方法：

public class Main {
    public static void main(String[] args) {
        System.out.println(addElements(5).await().indefinetely());
    }

    private static Uni<List<String>> addElements(final int elementsCount) {
        return Multi.createFrom()
                .range( 0, elementCount )
                .map( integer -> RandomStringUtils.randomAlphanumeric( 17 ).toUpperCase() )
                .collect()
                .asList();
    }
}

作为参考，在官方网站上有一个有用的入门指南