да и там лист прилетает, и нужно будет форич чтобы перебрать

и чтобы не писать это все в {  } вынес в маппер, что есть тру

так я содержимое маппера и написал
forEach обычно всё же для другого

хорошо, какую реализацию предложите?

весь код, что должен внутри вашей функции

но обычно всё же маппер пишется для одного элемента и его отдают в map

но в мап мне лист прилетает

и этот лист нужно смапить

с деф моделью так и есть

я говорил про котлиновский map: public inline fun <T, R> Iterable<T>.map(transform: (T) -> R): List<R>

а если вы подписались, то вы там итак уже получаете List

тоесть, что-то такое?

уже лучше

Привет, ребята, люблю этот чат.

Хотел бы спросить по клинке, был бы рад ответу.
Я получаю данные. В репозитории метод getData(), возвращающий Observable<Data>.
Репозиторий обращается к менеджеру, чтобы получить этот обсервейбл: firebaseManager.getData()

Я хочу проверить соединение интернета перед запросом, и если интернета нет - кинуть ошибку, типа NoInternetException.
А если интернет есть - возвратить обсервейбл из менеджера.

Вопрос - как это реализовать?

Как я понимаю, нужно сделать Observable.create в репозитории, в нем проверить на интернет, и если доступен - как-то вернуть обсервейбл из менеджера, если нет, то emitter.onError(NoInternetException())

Я бы в дата слое реализовал класс проверяющий интернет соединения, и провайдил репу в домейн, тоесть юз кейс бы принимала 2 репы, и чекал 🤔

Репозиторий может содержать другие репозитории?

Да

может, но это боль :(

Почему боль?

ну, слишком умное все получается
потом сидишь и репу чешешь, когда пытаешься решить, где ту или иную логику хранить (а ведь взаимодействие двух репозиториев - логика)