我们如何在Java 9中使用发布订阅模式来实现Flow API呢？

Flow API 由发布者、订阅者、订阅和处理器接口组成，这些接口可以基于反应式流规范。

在下面的示例中，我们可以使用发布者-订阅者接口来实现 Flow API。

示例

import java.util.concurrent.Flow.Publisher;
import java.util.concurrent.Flow.Subscriber;
import java.util.concurrent.Flow.Subscription;

public class FlowAPITest {
public static void main(String args[]) {
Publisher publisherSync = new Publisher() { // Create publisher
@Override
public void subscribe(Subscriber