在Java 9中执行Flow API的步骤是什么?
Java9中的FlowAPI对应于ReactiveStreams 规范,它是事实上的标准。它包含一组最少的接口,这些接口捕获了异步发布和订阅的核心。
以下是FlowAPI的关键接口:
1) 流程。发布者:它产生供订阅者使用的项目,并且仅包含方法:subscription(Subscriber),其目的应该很明显。
语法
void subscribe(Flow.Subscriber<? super T> subscriber)
2) 流程。订阅者:它订阅发布者(通常只有一个)来接收项目(通过方法onNext(T)),错误消息(onError(Throwable))或发出不再需要更多项目的信号(onComplete())。在任何这些事情发生之前,发布者都会调用onSubscription(Subscription) 方法。
语法
void onSubscribe(Flow.Subscription subscription) void onNext(T item) void onError(Throwable throwable) void onComplete()
3) 流程。订阅:单个发布者 和单个订阅者之间的连接。订户可以使用它来请求更多项目(request(long))或断开连接(cancel())。
语法
void request(long n) void cancel()
FlowAPI的执行步骤:
首先,我们需要创建一个Publisher 和一个Subscriber。
用Publisher::subscribe订阅订阅者。
该发行商 创建一个订阅 ,并呼吁用户::onSubscription有了它,所以用户可以存储订阅。
在某个时候,订户调用Subscription:: 请求 以请求多个项目。
发布者通过调用Subscriber::onNext开始将项目交给订阅者。它发布的内容绝不超过所请求的项目数。
发布者有时可能会遇到麻烦,并分别调用Subscriber::onComplete 或Subscriber::onError。
订户可能会继续不时请求更多项目,或者通过调用Subscription::cancel断开连接。
热门推荐
10 生日祝福语男孩 简短独特
11 祝愿女孩成长祝福语简短
12 求婚文案 祝福语大全简短
13 写给少女祝福语的话简短
14 上海返乡祝福语简短精辟
15 爸爸生日举杯祝福语简短
16 新年祝福语长辈简短红包
17 给导师送花祝福语简短
18 网友婚姻祝福语大全简短