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中文网其他相关文章!