再多几个例子

在这一节中，我们将基于RxJava的just(),repeat(),defer(),range(),interval(),和timer()方法展示一些例子。

just()

假如我们只有3个独立的AppInfo对象并且我们想把他们转化为Observable并填充到RecyclerView的item中：

  1. List<AppInfo> apps = ApplicationsList.getInstance().getList();
  3. AppInfo appOne = apps.get(0);
  5. AppInfo appTwo = apps.get(10);
  7. AppInfo appThree = apps.get(24);
  9. loadApps(appOne,appTwo,appThree);

我们可以像我们之前的例子那样检索列表并提取出这三个元素。然后我们将他们传到这个loadApps()函数里面：

  1. private void loadApps(AppInfo appOne,AppInfo appTwo,AppInfo appThree) {
  2.     mRecyclerView.setVisibility(View.VISIBLE);
  3.     Observable.just(appOne,appTwo,appThree)
  4.             .subscribe(new Observer<AppInfo>() {
  6.                 @Override
  7.                 public void onCompleted() {
  8.                     mSwipeRefreshLayout.setRefreshing(false);
  9.                     Toast.makeText(getActivity(), "Here is the list!", Toast.LENGTH_LONG).show();
  10.                 }
  12.                 @Override
  13.                 public void onError(Throwable e) {
  14.                     Toast.makeText(getActivity(), "Something went wrong!", Toast.LENGTH_SHORT).show();
  15.                     mSwipeRefreshLayout.setRefreshing(false);
  16.                 }
  18.                 @Override
  19.                 public void onNext(AppInfo appInfo) {
  20.                     mAddedApps.add(appInfo); 
  21.                     mAdapter.addApplication(mAddedApps.size() - 1,appInfo);
  22.                 }
  23.             });
  24. }

正如你看到的，代码和之前的例子很像。这种方法让我们有机会来考虑一下代码的复用。

你可以将一个函数作为参数传给just()方法，你将会得到一个已存在代码的原始Observable版本。在一个新的响应式架构的基础上迁移已存在的代码，这个方法可能是一个有用的开始点。

repeat()

假如你想对一个Observable重复发射三次数据。例如，我们用just()例子中的Observable：

  1. private void loadApps(AppInfo appOne,AppInfo appTwo,AppInfo appThree) {
  2.     mRecyclerView.setVisibility(View.VISIBLE);
  3.     Observable.just(appOne,appTwo,appThree)
  4.             .repeat(3)
  5.             .subscribe(new Observer<AppInfo>() {
  7.                 @Override
  8.                 public void onCompleted() {
  9.                     mSwipeRefreshLayout.setRefreshing(false);
  10.                     Toast.makeText(getActivity(), "Here is the list!", Toast.LENGTH_LONG).show();
  11.                 }
  13.                 @Override
  14.                 public void onError(Throwable e) {
  15.                     Toast.makeText(getActivity(), "Something went wrong!", Toast.LENGTH_SHORT).show();
  16.                     mSwipeRefreshLayout.setRefreshing(false);
  17.                 }
  19.                 @Override
  20.                 public void onNext(AppInfo appInfo) {
  21.                     mAddedApps.add(appInfo); 
  22.                     mAdapter.addApplication(mAddedApps.size() - 1,appInfo);
  23.                 }
  24.             });
  25. }

正如你看到的，我们在just()创建Observable后追加了repeat(3)，它将会创建9个元素的序列，每一个都单独发射。

defer()

有这样一个场景，你想在这声明一个Observable但是你又想推迟这个Observable的创建直到观察者订阅时。看下面的getInt()函数：

  1. private Observable<Integer> getInt(){
  2.     return Observable.create(subscriber -> {
  3.         if(subscriber.isUnsubscribed()){
  4.             return;
  5.         }
  6.         App.L.debug("GETINT");
  7.         subscriber.onNext(42);
  8.         subscriber.onCompleted();
  9.     });
  10. }

这比较简单，并且它没有做太多事情，但是它正好为我们服务。现在，我们可以创建一个新的Observable并且应用defer():

  1. Observable<Integer> deferred = Observable.defer(this::getInt);

这次，deferred存在，但是getInt() create()方法还没有调用:logcat日志也没有“GETINT”打印出来:

  1. deferred.subscribe(number -> {
  2.     App.L.debug(String.valueOf(number));
  3. });

但是一旦我们订阅了，create()方法就会被调用并且我们也可以在logcat日志中得到下卖弄两个：GETINT和42。

range()

你需要从一个指定的数字X开始发射N个数字吗？你可以用range:

  1. Observable.range(10,3)
  2.     .subscribe(new Observer<Integer>() {
  4.         @Override
  5.         public void onCompleted() {
  6.             Toast.makeText(getActivity(), "Yeaaah!", Toast.LENGTH_LONG).show();
  7.         }
  9.         @Override
  10.         public void onError(Throwable e) {
  11.             Toast.makeText(getActivity(), "Something went wrong!", Toast.LENGTH_SHORT).show();
  12.         }
  14.         @Override
  15.         public void onNext(Integer number) {
  16.             Toast.makeText(getActivity(), "I say " + number, Toast.LENGTH_SHORT).show();
  17.         }
  18.     });

range()函数用两个数字作为参数：第一个是起始点，第二个是我们想发射数字的个数。

interval()

interval()函数在你需要创建一个轮询程序时非常好用。

  1. Subscription stopMePlease = Observable.interval(3,TimeUnit.SECONDS)
  2.     .subscribe(new Observer<Integer>() {
  4.         @Override
  5.         public void onCompleted() {
  6.             Toast.makeText(getActivity(), "Yeaaah!", Toast.LENGTH_LONG).show();
  7.         }
  9.         @Override
  10.         public void onError(Throwable e) {
  11.             Toast.makeText(getActivity(), "Something went wrong!", Toast.LENGTH_SHORT).show();
  12.         }
  14.         @Override
  15.         public void onNext(Integer number) {
  16.             Toast.makeText(getActivity(), "I say " + number, Toast.LENGTH_SHORT).show();
  17.         }
  18.     });

interval()函数的两个参数：一个指定两次发射的时间间隔，另一个是用到的时间单位。

timer()

如果你需要一个一段时间之后才发射的Observable，你可以像下面的例子使用timer()：

  1. Observable.timer(3,TimeUnit.SECONDS)
  2.     .subscribe(new Observer<Long>() {
  4.         @Override
  5.         public void onCompleted() {
  7.         }
  9.         @Override
  10.         public void onError(Throwable e) {
  12.         }
  14.         @Override
  15.         public void onNext(Long number) {
  16.             Log.d("RXJAVA", "I say " + number);
  17.         }
  18.     });

它将3秒后发射0,然后就完成了。让我们使用timer()的第三个参数，就像下面的例子：

  1. Observable.timer(3,3,TimeUnit.SECONDS)
  2.     .subscribe(new Observer<Long>() {
  4.         @Override
  5.         public void onCompleted() {
  7.         }
  9.         @Override
  10.         public void onError(Throwable e) {
  12.         }
  14.         @Override
  15.         public void onNext(Long number) {
  16.             Log.d("RXJAVA", "I say " + number);
  17.         }
  18.     });

用这个代码，你可以创建一个以初始值来延迟（上一个例子是3秒）执行的interval()版本，然后每隔N秒就发射一个新的数字（前面的例子是3秒）。