Проблема преобразования массива <T>в наблюдаемыеиспользуя RxJava2

Question

В основном я пытаюсь вернуть Observable<Array<T>>.Я дважды проверил, что getAllCategoriesFromDB() возвращает Array<Categroies>.categoryDao является классом kotlin.

Я пытался использовать этот код:

fun getAllCategoriesFromDB(): Observable<Array<Categories>>
    {
        return categoryDao.selectAllCategories().toObservable()
    }

Однако возвращаемый тип Observable<Categories> вместо Observable<Array<Categories>>

Я следовалпример из здесь (прокрутите вниз до кода примера репозитория)

My selectAllCategories() выглядит так (имейте в виду, что я использую Room):

@Query("SELECT * FROM Categories")
    fun selectAllCategories(): Array<Categories>

Помощь или совет будут высоко оценены, так как я впервые работаю с RxJava2.

Answer 1

Я решил это с помощью этого кода.Возможно, он не выглядит чистым или лучшим решением, но, по крайней мере, работает:

var categories = categoryDao.selectAllCategories()
var observable = Observable.fromArray(categories)