then(mGithubApi).should(timeout(100).only())
.searchGithubUsers(anyString(), anyString(), anyString());
}
@Test
public void testSearchUserApiError() {
<BUG>willReturn(Observable.create(
(Observable.OnSubscribe<GithubUserSearchResult>) subscriber -> {
subscriber.onError(TestUtil.apiError());
})).given(mGithubApi).searchGithubUsers(anyString(), anyString(), anyString());
final TestSubscriber<List<GithubUser>> subscriber = new TestSubscriber<>();</BUG>
mGithubUserRepo.searchUser("Piasy").subscribe(subscriber);

then(mGithubApi).should(timeout(100).only())
.searchGithubUsers(anyString(), anyString(), anyString());
}
@Test
public void testSearchUserApiError() {
willReturn(Flowable.create(emitter -> emitter.onError(TestUtil.apiError()),
BackpressureStrategy.BUFFER))
.given(mGithubApi)
.searchGithubUsers(anyString(), anyString(), anyString());
final TestSubscriber<List<GithubUser>> subscriber = new TestSubscriber<>();
mGithubUserRepo.searchUser("Piasy").subscribe(subscriber);
