java rxjava

作者:原创时间:2022-04-19
文档

java rxjava是什么?让我们一起来了解一下吧!

java rxjava是java程序中的响应式编程。所谓响应式编程,是指一种基于异步数据流概念的编程模式Rxjava的完整英文名称是reactivexjava,它是一个数据库,作用是支持需要异步控制的地方。与handler相比,rxjava更具备简洁性。

rxjava有以下几个独特点:

1. <1mb jar

2. 轻量级框架

3. 可以在java 8 lambda运行

4. 可以在java 6+&android 2.3+运行

5. 同步或者异步都可以

实战演练,具体步骤如下:

package top.onefine.rxjava;
 
import lombok.extern.slf4j.Slf4j;
import rx.Observable;
import rx.Subscriber;
 
@Slf4j
public class HelloWorld {
 
    public static void main(String[] args) {
        // 1. 创建被观察者
        Observable observable = Observable.create(subscriber -> {
            subscriber.onNext("Hello world.");
            throw new NullPointerException("Throw a Exception...");
//            subscriber.onCompleted();
        });
 
        // 2. 创建观察者
        Subscriber subscriber = new Subscriber() {
 
            @Override
            public void onCompleted() {
                log.info("onCompleted...");
            }
 
            @Override
            public void onError(Throwable e) {
                log.info("onError...");
            }
 
            @Override
            public void onNext(String s) {
                log.info("onNext: {}", s);
            }
        };
 
        // 3. 订阅事件
        observable.subscribe(subscriber);
    }
}

以上就是小编今天的分享了,希望可以帮助到大家。

显示全文
java sandbox java script java selector java selenium java semaphore java separator java sequence java serializable java serializable接口 java serialversionuid java setlayout java platform java settimeout java plug-in java sftp java plugin java pojo java portal java sha256加密 java shuffle java runtime.exec java runnable java rtp java rsa私钥加密 java rsa公钥加密 java pipeline java ping java phoenix java paypal java path java rsa加密 java rotate java reverse java reverse() java retrofit java resume java resultset java result java rest java requests