多出版商

Question

第一次使用 Multi，我做错了什么。我想使用 java.util.concurrent 中的 SubmissionPublisher。它实现了 Flow.Publisher 接口。

final SubmissionPublisher<String> subPub1 = new SubmissionPublisher<>();
final var m1 = Multi.createFrom().publisher(subPub1);

Multi.createFrom.publishers 的签名表明参数需要实现 Flow.Publisher。但是，我收到类型错误。

The method publisher(Publisher<T>) in the type MultiCreate is not applicable for the arguments (SubmissionPublisher<String>)

我试过用两种不同的方式投射它：

final var m1 = Multi.createFrom().publisher((java.util.concurrent.Flow.Publisher<String>) subPub1);

和

final var m1 = Multi.createFrom().publisher((Publisher<String>) subPub1);

但我仍然收到错误：

The method publisher(Publisher<T>) in the type MultiCreate is not applicable for the arguments (Flow.Publisher<String>)

对我做错了什么有任何见解吗？

Answer 1

也许你可以使用org.reactivestreams.FlowAdapters；

var flowPublisher = new SubmissionPublisher<String>();
var multi = Multi.createFrom().publisher(FlowAdapters.toPublisher(flowPublisher));