Java 9中的Reactive Streams的核心接口是什么？

Flow API包含四个相互关联的核心接口：发布者、订阅者、订阅和< strong>处理器。

语法

@FunctionalInterface
public static interface Publisher<T> {
   public void subscribe(Subscriber<? super T> subscriber)
}
public static interface Subscriber<T> {
   public void onSubscribe(Subscription subscription);
   public void onNext(T item);
   public void onError(Throwable throwable);
   public void onComplete();
}
public static interface Subscription {
   public void request(long n);
   public void cancel();
}
public static interface Processor<T, R> extends Subscriber<T>, Publisher<R> {
}

这四个接口：Flow.Publisher、Flow.Processor、Flow.Subscriber 和 Flow 。与反应流规范相关的订阅。 发布者接口有subscribe()方法，订阅有cancel()和request()< /strong> 方法，订阅者有 onSubscribe()、onNext()、onError() 和 >onComplete() 方法。 处理器接口实现Flow的所有方法。发布者和Flow.Subscriber 接口。

以上就是Java 9中的Reactive Streams的核心接口是什么？的详细内容，更多请关注php中文网其它相关文章！