Текучий для наблюдаемого в Котлине с Rx

Question

Я должен преобразовать Flowable в Observable и теперь использовать этот код:

return entityDao.getAll()
            .flatMap { list ->
                Flowable.just(list).map {
                    it.map {
                        it.transformToDomain()
                    }
                }
            }
            .toObservable()

getAll возвращает Flowable>.Но я хочу изменить его на этот, и он не работает:

    return wordDao.getAll()
            .flatMap { list ->
              Observable.just(list).map {
                it.map {
                    it.transformToDomain()
                }
            }

Может ли кто-нибудь помочь?