无法将供应商功能接口变量应用于 Flux.fromStream 方法

问题描述

嗨，我是 Web Flux 和声明式编程风格的新手。

假设我有

List<String> numbers = Arrays.asList("one","two","three");

然后我转换成流

Stream<String> streamNumbers = numbers.stream();

我需要将此流转换为 Flux<String> 对象。在 Flux 类中，我有两个静态方法签名来做到这一点

public static <T> Flux<T> fromStream(Stream<? extends T> s)
public static <T> Flux<T> fromStream(supplier<Stream<? extends T>> streamsupplier)

我喜欢使用供应商功能接口，因为这样我就可以拥有一个管道。但问题是我什么时候喜欢这个

Flux.fromStream(() -> streamNumbers);

它工作正常。但是当我将它分配给这样的变量时

supplier<Stream<String>> streamsupplier = () -> streamNumbers;

这个变量适用于这样的 fromStream 方法

Flux.fromStream(streamsupplier);

IntellJ 提示我这样的错误

Cannot resolve method 'fromStream(java.util.function.supplier<java.util.stream.Stream<java.lang.String>>)

我需要知道为什么会这样？？？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）