Привет всем. Пытаюсь разобраться с тестированием кода на rxJava, но получается фигня какая-то.
написал тест для репозитория:
val query = "query"
val itemsCount=10
given(dao.getOutlets(query))
.willReturn(
FlowableCreate.create<List<OutletDbDto>>(
{ List(itemsCount, { q -> OutletDbDto()})}, BackpressureStrategy.LATEST)
)
repository.getOutlets(query)
.test()
// .await()
.assertValueCount(itemsCount)
.assertOf { q-> verify(dao).getOutlets(query) }
падает с ошибкой
Value counts differ; Expected: 10, Actual: 0 (latch = 1, values = 0, errors = 0, completions = 0)
хотя метод дао вызывает сам репозиторий вызывает
return outletDao.getOutlets(searchQuery)
.map { q-> OutletListModel(
q.map { e->OutletModel(e) })}