java - 单元测试 - 验证 Observable 是否被订阅

Question

我有这样的java代码

 mDataManager.getObservable("hello").subscribe( subscriber );

我想验证下面的 Observable 正在 .subscribe()

我已经尝试模拟 getObservable() 和 verify

 Observable<Response> res = mock(Observable.class);
 when(mDataManager.getObservable("hello")).thenReturn(res);
 verify(res).subscribe();

但是有错误

Caused by: java.lang.IllegalStateException: onSubscribe function can not be null.
at rx.Observable.subscribe(Observable.java:8167)
at rx.Observable.subscribe(Observable.java:8158)
at rx.Observable.subscribe(Observable.java:7962)
....
Caused by: rx.exceptions.OnErrorThrowable$OnNextValue: OnError while emitting onNext value: omni.neo.hk.omniapiservice.v4.model.external.UserLoginBean.class
at rx.exceptions.OnErrorThrowable.addValueAsLastCause(OnErrorThrowable.java:109)
at rx.exceptions.Exceptions.throwOrReport(Exceptions.java:187)
at rx.internal.operators.OperatorDoOnEach$1.onNext(OperatorDoOnEach.java:82)
... 48 more

我认为这里不可能mock一个Observable，但是没有一个mocked Observable我不能verify(res).subscribe()

在这种情况下有什么建议吗？

Answer 1

我发现RxJava提供了一个类叫TestSubject

你可以这样创建它

private TestScheduler eventsScheduler = new TestScheduler();
private TestSubject<MyEvent> eventObservable = TestSubject.create(eventsScheduler);

这将为您提供返回 boolean 值的方法 hasObservers()。

@Test
public void testSubscription(){
    myTestClass.init(eventObservable);

    assertTrue(eventObservable.hasObservers());
}

此外，TestSubject 还允许您完美地确定何时应该发送事件。

eventObservable.onNext(new MyEvent());
eventsScheduler.triggerActions();