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

just()

假如我们只有3个独立的AppInfo对象并且我们想把他们转化为Observable并填充到RecyclerView的item中:
1
List<AppInfo> apps = ApplicationsList.getInstance().getList();
2
3
AppInfo appOne = apps.get(0);
4
5
AppInfo appTwo = apps.get(10);
6
7
AppInfo appThree = apps.get(24);
8
9
loadApps(appOne,appTwo,appThree);
Copied!
我们可以像我们之前的例子那样检索列表并提取出这三个元素。然后我们将他们传到这个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>() {
5
6
@Override
7
public void onCompleted() {
8
mSwipeRefreshLayout.setRefreshing(false);
9
Toast.makeText(getActivity(), "Here is the list!", Toast.LENGTH_LONG).show();
10
}
11
12
@Override
13
public void onError(Throwable e) {
14
Toast.makeText(getActivity(), "Something went wrong!", Toast.LENGTH_SHORT).show();
15
mSwipeRefreshLayout.setRefreshing(false);
16
}
17
18
@Override
19
public void onNext(AppInfo appInfo) {
20
mAddedApps.add(appInfo);
21
mAdapter.addApplication(mAddedApps.size() - 1,appInfo);
22
}
23
});
24
}
Copied!
正如你看到的,代码和之前的例子很像。这种方法让我们有机会来考虑一下代码的复用。
你可以将一个函数作为参数传给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>() {
6
7
@Override
8
public void onCompleted() {
9
mSwipeRefreshLayout.setRefreshing(false);
10
Toast.makeText(getActivity(), "Here is the list!", Toast.LENGTH_LONG).show();
11
}
12
13
@Override
14
public void onError(Throwable e) {
15
Toast.makeText(getActivity(), "Something went wrong!", Toast.LENGTH_SHORT).show();
16
mSwipeRefreshLayout.setRefreshing(false);
17
}
18
19
@Override
20
public void onNext(AppInfo appInfo) {
21
mAddedApps.add(appInfo);
22
mAdapter.addApplication(mAddedApps.size() - 1,appInfo);
23
}
24
});
25
}
Copied!
正如你看到的,我们在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
}
Copied!
这比较简单,并且它没有做太多事情,但是它正好为我们服务。现在,我们可以创建一个新的Observable并且应用defer():
1
Observable<Integer> deferred = Observable.defer(this::getInt);
Copied!
这次,deferred存在,但是getInt() create()方法还没有调用:logcat日志也没有“GETINT”打印出来:
1
deferred.subscribe(number -> {
2
App.L.debug(String.valueOf(number));
3
});
Copied!
但是一旦我们订阅了,create()方法就会被调用并且我们也可以在logcat日志中得到下卖弄两个:GETINT和42。

range()

你需要从一个指定的数字X开始发射N个数字吗?你可以用range:
1
Observable.range(10,3)
2
.subscribe(new Observer<Integer>() {
3
4
@Override
5
public void onCompleted() {
6
Toast.makeText(getActivity(), "Yeaaah!", Toast.LENGTH_LONG).show();
7
}
8
9
@Override
10
public void onError(Throwable e) {
11
Toast.makeText(getActivity(), "Something went wrong!", Toast.LENGTH_SHORT).show();
12
}
13
14
@Override
15
public void onNext(Integer number) {
16
Toast.makeText(getActivity(), "I say " + number, Toast.LENGTH_SHORT).show();
17
}
18
});
Copied!
range()函数用两个数字作为参数:第一个是起始点,第二个是我们想发射数字的个数。

interval()

interval()函数在你需要创建一个轮询程序时非常好用。
1
Subscription stopMePlease = Observable.interval(3,TimeUnit.SECONDS)
2
.subscribe(new Observer<Integer>() {
3
4
@Override
5
public void onCompleted() {
6
Toast.makeText(getActivity(), "Yeaaah!", Toast.LENGTH_LONG).show();
7
}
8
9
@Override
10
public void onError(Throwable e) {
11
Toast.makeText(getActivity(), "Something went wrong!", Toast.LENGTH_SHORT).show();
12
}
13
14
@Override
15
public void onNext(Integer number) {
16
Toast.makeText(getActivity(), "I say " + number, Toast.LENGTH_SHORT).show();
17
}
18
});
Copied!
interval()函数的两个参数:一个指定两次发射的时间间隔,另一个是用到的时间单位。

timer()

如果你需要一个一段时间之后才发射的Observable,你可以像下面的例子使用timer()
1
Observable.timer(3,TimeUnit.SECONDS)
2
.subscribe(new Observer<Long>() {
3
4
@Override
5
public void onCompleted() {
6
7
}
8
9
@Override
10
public void onError(Throwable e) {
11
12
}
13
14
@Override
15
public void onNext(Long number) {
16
Log.d("RXJAVA", "I say " + number);
17
}
18
});
Copied!
它将3秒后发射0,然后就完成了。让我们使用timer()的第三个参数,就像下面的例子:
1
Observable.timer(3,3,TimeUnit.SECONDS)
2
.subscribe(new Observer<Long>() {
3
4
@Override
5
public void onCompleted() {
6
7
}
8
9
@Override
10
public void onError(Throwable e) {
11
12
}
13
14
@Override
15
public void onNext(Long number) {
16
Log.d("RXJAVA", "I say " + number);
17
}
18
});
Copied!
用这个代码,你可以创建一个以初始值来延迟(上一个例子是3秒)执行的interval()版本,然后每隔N秒就发射一个新的数字(前面的例子是3秒)。