blob: 248718441a243b9aee23c60c319d13143d57c9e9 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
package cgeo.geocaching.utils;
import static org.assertj.core.api.Assertions.assertThat;
import rx.Observable;
import rx.Subscription;
import rx.functions.Func1;
import rx.subjects.PublishSubject;
import rx.subjects.ReplaySubject;
import android.test.AndroidTestCase;
public class RxUtilsTest extends AndroidTestCase {
// Observable.range(int, int) is not kept in the application by proguard. Use an explicit range here.
private static final ReplaySubject<Integer> range = ReplaySubject.createWithSize(10);
static {
for (int i = 1; i <= 10; i++) {
range.onNext(i);
}
range.onCompleted();
}
public static void testTakeUntil() {
final Observable<Integer> observable = range.lift(RxUtils.operatorTakeUntil(new Func1<Integer, Boolean>() {
@Override
public Boolean call(final Integer value) {
return value > 6;
}
}));
assertThat(observable.toList().toBlocking().single().toArray()).isEqualTo(new int[]{1, 2, 3, 4, 5, 6, 7});
}
public static void testRememberLast() {
final PublishSubject<String> rawObservable = PublishSubject.create();
final Observable<String> observable = RxUtils.rememberLast(rawObservable, "initial");
// Check that the initial value is present, and is kept there
assertThat(observable.toBlocking().first()).isEqualTo("initial");
assertThat(observable.toBlocking().first()).isEqualTo("initial");
// Check that if the observable is not subscribed, changes are not propagated (similar to not keeping the
// inner subscription active).
rawObservable.onNext("without subscribers");
assertThat(observable.toBlocking().first()).isEqualTo("initial");
// Check that new values are propagated and cached
final Subscription subscription = observable.subscribe();
rawObservable.onNext("first");
assertThat(observable.toBlocking().first()).isEqualTo("first");
subscription.unsubscribe();
assertThat(observable.toBlocking().first()).isEqualTo("first");
}
}
|
