我有这样的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()
在这种情况下有什么建议吗?
最佳答案
我发现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();
关于java - 单元测试 - 验证 Observable 是否被订阅,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40500312/