RXJAVA-doOnNext

网友投稿 277 2022-11-24

RXJAVA-doOnNext

它的作用是让订阅者在接收到数据之前干点有意思的事情。假如我们在获取到数据之前想先保存一下它,无疑我们可以这样实现。 package com.netty.demo.vertx; import io.reactivex.*; import io.reactivex.functions.Consumer; import lombok.extern.slf4j.Slf4j; @Slf4j public class RxJavaTest { public static void main(String[] args) throws InterruptedException { Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter emitter) throws Exception { emitter.onNext(1); emitter.onNext(2); emitter.onNext(3); } }).doOnNext(new Consumer() { @Override public void accept(Integer integer) throws Exception { log.info("doOnNext:" + integer); } }).subscribe(new Consumer() { @Override public void accept(Integer integer) throws Exception { log.info(integer.toString()); } }); Thread.sleep(300000000); } }   2021-02-23 17:16:13 [main] INFO  c.n.d.v.RxJavaTest:accept - doOnNext:1 2021-02-23 17:16:13 [main] INFO  c.n.d.v.RxJavaTest:accept - 1 2021-02-23 17:16:13 [main] INFO  c.n.d.v.RxJavaTest:accept - doOnNext:2 2021-02-23 17:16:13 [main] INFO  c.n.d.v.RxJavaTest:accept - 2 2021-02-23 17:16:13 [main] INFO  c.n.d.v.RxJavaTest:accept - doOnNext:3 2021-02-23 17:16:13 [main] INFO  c.n.d.v.RxJavaTest:accept - 3

版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:PLC由哪几部分组成
下一篇:关于Java 项目封装sqlite连接池操作持久化数据的方法
相关文章

 发表评论

暂时没有评论,来抢沙发吧~