找到是否有至少一个-可观察Java8 Rx

Question

我有一个可观察的

为了更好地解释：

Observable<SomeObject> thing = someFunction();
thing.flatMap(c -> c.toObservable())
.filter(q -> someContidion(q))
.forEach(x -> Assert.assertTrue(x!=null));

当然这不是我需要的，因为如果没有匹配条件的元素，我就看不到任何错误，单元测试也通过了。




Answer 1

另一种方法是使用RxJava项目已经在自己的测试用例中使用的东西，这就是TestSubcriber（TestScheduler在某个时候也可能对您有用）：

@RunWith(JUnit4.class)
public class RxTest {

    @Test
    public void test() throws Exception {
        Observable<String> thing = Observable.just("thing", "stuff", "whatever", "", null);
        Observable<Boolean> test = thing.contains("thing");

        TestSubscriber<Boolean> sub = new TestSubscriber<>();
        test.subscribe(sub);

        sub.assertValue(true);
    }
}