Flow API 是自 Java 9 以来对反应式流规范的官方支持。它是 Iterator 和 Observer 的组合模式。 Flow API 是一种互操作规范，而不是像 RxJava 这样的最终用户 API。
Flow API 由四个基本接口组成：
在下面的示例中，我们创建了一个基本订阅者，它请求一个数据对象，打印它并请求另一个数据对象。我们可以使用 Java 提供的发布者实现 (SubmissionPublisher) 来完成我们的会话。
import java.util.concurrent.Flow;
import java.util.List;
import java.util.concurrent.SubmissionPublisher;
class MySubscriber<T>implements <strong>Flow.Subscriber<T></strong> {
private <strong>Flow.Subscription</strong> subscription;
<strong>@Override</strong>
public void <strong>onSubscribe</strong>(Flow.Subscription subscription) {
this.subscription = subscription;
this.subscription.request(1);
}
<strong>@Override</strong>
public void <strong>onNext</strong>(T item) {
System.out.println(item);
subscription.request(1);
}
<strong>@Override</strong>
public void <strong>onError</strong>(Throwable throwable) {
throwable.printStackTrace();
}
<strong>@Override</strong>
public void <strong>onComplete</strong>() {
System.out.println("Done");
}
}
<strong>// main class</strong>
public class FlowTest {
public static void main(String args[]) {
<strong>List<String></strong> items = <strong>List.of</strong>("1", "2", "3", "4", "5", "6", "7", "8", "9", "10");
<strong>SubmissionPublisher<String></strong> publisher = new SubmissionPublisher<>();
publisher.<strong>subscribe</strong>(new MySubscriber<>());
items.forEach(s -> {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
publisher.<strong>submit</strong>(s);
});
publisher.close();
}
}<strong>1 2 3 4 5 6 7 8 9</strong> <strong>10 Done</strong>
以上是如何在Java 9中使用Flow API实现响应式流？的详细内容。更多信息请关注PHP中文网其他相关文章！
