Работал ли с RxJava

А, RxJava? Да, работал, конечно. Эта штука — просто ёперный театр для асинхронщины, пока в ней не начнёшь копаться. Вроде бы всё красиво: Observable, Flowable, вся эта ваша реактивная магия. Но как только пытаешься собрать цепочку посложнее, сразу чувствуешь, что подозрение ебать чувствую — сейчас всё накроется медным тазом.

Вот смотри, классический пример, который все в туториалах суют:

Observable.just("Hello", "RxJava")
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe { text -> Log.d("RxJava", text) }

Вроде просто, да? Кинул данные в поток, обработал в фоне, результат поймал в главном потоке. Красота. Но это только верхушка айсберга, чувак.

А теперь представь, что у тебя не два слова, а, допустим, список пользователей, которых надо запросить с сервера, потом для каждого вытащить его аватарку из кэша, а если её нет — скачать, потом всё это скомпоновать и отрисовать в RecyclerView. И всё это должно не уронить приложение, если пользователь свернул его на полпути. Вот тут начинается настоящий пиздец, прости мой французский.

Ключевые моменты, на которых все обжигаются:

• Schedulers (IO, Computation, MainThread). Казалось бы, что тут сложного? IO — для диска и сети, Computation — для тяжёлых вычислений, MainThread — для отрисовки. Ан нет! Сунешь не в тот поток — и приложение виснет, как будто хуй с горы на него упал. Получаешь NetworkOnMainThreadException и сам от себя охуеваешь. Главное правило: всё, что дольше милисекунды — в бэкграунд.
• Operators (map, filter, flatMap). Это вообще отдельная религия. flatMap, например, — это такая хитрая жопа. Он может распараллелить запросы, а может и не распараллелить, смотря как использовать. И если ты внутри flatMap сделаешь блокирующую операцию не на том шедулере, то доверия ебать ноль к стабильности твоего стрима.
• Disposable. А вот это, блядь, святое. Самый частый грабель. Запустил подписку — обязательно сохрани Disposable. Не сохранил? Поздравляю, у тебя теперь утечка памяти, потому что подписка жива, пока жив Observable, а он может жить долго и счастливо, держа ссылку на твой контекст Activity. А потом приложение падает от OutOfMemory, и ты терпения ноль ебать, сидишь и ищешь, где же ты забыл вызвать .dispose() или не добавил в CompositeDisposable. Это прям must have, иначе будет хиросима и нигерсраки в проде.

Использовал её, конечно, для всего: и для сетевых запросов через Retrofit, и для обработки кликов по интерфейсу, чтобы не плодить кучу слушателей, и для сложных цепочек, где данные из одного источника нужно преобразовать, отфильтровать и склеить с данными из другого. Когда всё работает — это овердохуища кайфа. Чувствуешь себя повелителем потоков и данных.

Но когда что-то ломается и стрим молча сбрасывается с ошибкой где-то внутри цепочки из пяти flatMap... Вот тут начинается ебушки-воробушки. Дебаг превращается в шаманство с логированием каждого оператора. Так что инструмент мощный, но требующий уважения и понимания, что под капотом. А иначе — пиzда рулю.