тебе)

В listNotes записи постоянно буду накапливаться
Его очищать надо в методе getListNotes

а где потоки указываются? не в UI же это выполняется?

Дело в том, то что это не мои наработки

Но мне нужно все это в rx перевести

для внедрения в программу

Потоки не в ui выполняются

сам сижу разбираюсь

Поэтому нужна ваша помощь

Блин, про потоки не мне было?)))

тебе
там пример вызова из фрагмента, и потоки не указываются в нем

Значит не зря добавил.)))

Вроде поправил код согласно вашим замечаниям.
Если не сложно, посмотрите еще раз. Все ли верно я понял и исправил. Заранее спасибо.

А где смотреть?

С listNotes сложно получилось
Лучше его тогда вообще создавать внутри функции getListNotes

Посмотрите я все правильно сделал?

try {
           subscription = Observable
                   .just(Global.parsers.getCatalog(internet.getURLStringRX(query)))
                   .subscribeOn(Schedulers.io())
                   .observeOn(AndroidSchedulers.mainThread())
                   .subscribe(
                           catalogClasses -> {arrayList = catalogClasses; FullCatalog(catalogClasses);},
                           throwable -> {Log.d("RXJAVA", "Throwable = " + throwable);});
       } catch (XmlPullParserException e) {
           e.printStackTrace();
       } catch (IOException e) {
           e.printStackTrace();
       }

Получаю данные в виде xml файла

Сразу парсю