亚洲城娱乐rxjava 条件判别

( 亚洲城娱乐 )

我想完成如许一个服从,用户点击获取数据库数据,若数据库有这个数据,则直接表现外地的,若数据库没有这个数据,就从效力器央求再表现出来。
讨教一下用rxjava要怎样写呢?

1.先把服从函数写出来.

  private static Object loadFromCache(String key) {
      //....外地缓存加载,假如加载失败前往 null
  }
  private static Object loadFromServer(String key) {
      //....经过网络加载,前往数据
      Object obj = ....
      saveToCache(key, obj);//保管到外地缓存
      return obj;
  }

2.将壅闭办法转为RxJava的写法

    private static Observable<Object> rxLoadFromCache(String key) {
        return Observable.fromCallable(() -> loadFromCache(key));
    }

    private static Observable<Object> rxLoadFromServer(String key) {
        return Observable.fromCallable(() -> loadFromServer(key));
    }

3.吞并到一同

    public static Observable<Object> rxLoad(String key) {
        return Observable.concat(
                rxLoadFromCache(key),
                rxLoadFromServer(key)
        ).filter(obj -> obj != null)
         .take(1);
    }

4.调用最后的办法

    rxLoad(key)
          .subscribeOn(Schedulers.io())
          .subscribe(obj->{
                    System.out.println(obj);
    });

Observable.concat(Observable.just(null), Observable.just(1))
                .filter(integer -> integer != null)
                .take(1)
                .subscribe(integer -> {
                    //TODO
                });

Observable.if(
  () -> {
    return hasCache;
  },
  Observable.just(cache),
  Observable.just(database),
);

(看完/读完)这篇文章有何感想! 亚洲城娱乐的分享…

发表评论

电子邮件地址不会被公开。 必填项已用*标注