Mockito.when(searchDataModel.getSearchResultsOnceAndStream())
.thenReturn(searchResultsStream);
Mockito.when(searchDataModel.clear()).thenReturn(Completable.complete());
Mockito.when(searchDataModel.querySearch(anyString()))
.thenReturn(Completable.complete());
<BUG>withSuccessfulSearchResultStream();
}</BUG>
ArrangeBuilder withTimeScheduler(Scheduler scheduler, String tag) {
TimeScheduler.setTimeSchedulerHandler((s, t) ->
t.endsWith(tag)

Mockito.when(searchDataModel.getSearchResultsOnceAndStream())
.thenReturn(searchResultsStream);
Mockito.when(searchDataModel.clear()).thenReturn(Completable.complete());
Mockito.when(searchDataModel.querySearch(anyString()))
.thenReturn(Completable.complete());
withSuccessfulSearchResultStream();
withTimeSkipScheduler();
}
ArrangeBuilder withTimeScheduler(Scheduler scheduler, String tag) {
TimeScheduler.setTimeSchedulerHandler((s, t) ->
t.endsWith(tag)
