From 0ece2fb2aa4b602c8e1a70f46c8610c0bfc08d1c Mon Sep 17 00:00:00 2001 From: Samuel Tardieu Date: Thu, 5 Feb 2015 18:23:01 +0100 Subject: Use operator TakeUntil from RxJava 1.0.5 --- tests/src/cgeo/geocaching/utils/RxUtilsTest.java | 11 ----------- 1 file changed, 11 deletions(-) (limited to 'tests') diff --git a/tests/src/cgeo/geocaching/utils/RxUtilsTest.java b/tests/src/cgeo/geocaching/utils/RxUtilsTest.java index 2487184..cc8589b 100644 --- a/tests/src/cgeo/geocaching/utils/RxUtilsTest.java +++ b/tests/src/cgeo/geocaching/utils/RxUtilsTest.java @@ -4,7 +4,6 @@ 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; @@ -21,16 +20,6 @@ public class RxUtilsTest extends AndroidTestCase { range.onCompleted(); } - public static void testTakeUntil() { - final Observable observable = range.lift(RxUtils.operatorTakeUntil(new Func1() { - @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 rawObservable = PublishSubject.create(); final Observable observable = RxUtils.rememberLast(rawObservable, "initial"); -- cgit v1.1