RxJava - Observable, Flowable. Полный обзор. Часть 1. [RU, Android] / Мобильный разработчик 

Спасибо огромное за вашу помощь!

Чуть позже закреплю )

@@MobileDeveloper Завсегда пожалуйста ))

Вам спасибо ) вторую часть начал писать. Буду рад если поделитесь в соц сетях.

Всегда пожалуйста )

Спасибо ) рад, что понравилось )

Не знаю, тут надо смотреть конкретный код, но скорей всего что-то не так)

Пожалуйста)

Критика - это всегда хорошо. Для начала скажу, что и в ролике я говорил, что это только первая часть. Она итак получилась почти на час. А я по сути ввел только основные термины. Дальше будем углубляться в уже более серьезные и глубокие детали. Если бы я все это сделал в одном видео - оно бы вышло часа на 4 ) Так что в следующих видео уже будет более подробно. Здесь пока вводная тематика с определением основных терминов. Плюс разницу между Observable, Flowable, Single, Maybe и Completable я вроде показал.

Все умничают. Я тоже хочу) На самом деле автор впринципе ответил на этот вопрос во введении, когда сказал: "вы можете принять\выполнить любой модуль, как источник данных и подписываться на них в модуле, который от этих данных зависит". Тут стоит смотреть немного шире. Представте себе магазин. Есть склад есть прилавки. В контексте данного примера склад - источник данных. Так вот реактивный подход не предлагает вам готовой архитектуры склада. Он лишь предлагает вам заставить чувака на складе оповещать чуваков на прилавках о том, что ему завезли, когда ему что-то завезли. Вместо того, чтобы чуваки с прилавков периодически по каким-либо триггерам бегали на склад проверять, не привезли\забрали\разбили ли интересующий их товар. Тот же самый подход используется к примеру, когда вы работаете с сервером при помощи сокетов. Кому кого слушать - решать вам и это уже вопрос общей архитектуры приложения(кстати у автора есть видео на эту тему). К примеру модуль , который отвечает за обработку данных(обычно его реализуют по шаблону "репозиторий") может предоставлять наблюдаемых для презентеров\вью-моделей\контроллеров и т.д. И он же может прослушивать объекты классов, предоставляющих доступ к определенным источникам данных. Но не факт, что в каждом приложении есть смысл заводить такой модуль. Это уже разработчик решает исходя из задачи, переспективы расширения функционала и еще херовой тучи разных факторов. Сладовательно: - собственно для замены императивного(колбеков) взаимодействия модулей на реактивный он и нужен. - не уверен, что понял вопрос. Интерфейс существует для абстрагирования от имплементации. И если ваш модуль предоставляет доступ к данным - конечно в интерфейсе нужно указать, что возвращаемым типом некоего метода будет обсервер - нет. Слепо совать куда попало не нужно. К примеру я использую прослушку данных между слоями: DataSources -> Repositories -> Domain(логика) -> presenter. А вот между презентером и вьюшкой - классическая императивщина т.к. это общение происходит исключительно синхронно. Более того, вьюшка никогда не интересуется результатом вызова. Она оповестила презентер о том , что: "Меня нажали. Вот тут". А там хоть трава не рости. Это уже не ее забота. Ух... наумничался)))

😁😁

Право слово аж засмущали ) пожалуйста )

Спасибо большое!) про тайм коды подумаю ) если вы их добавите я закреплю ваш комментарий под видео )

@@MobileDeveloper Хорошо, когда буду пересматривать, а пересматривать придется ))) если не забуду, то соберу постепенно

Буду очень благодарен!)))

@@schnaps1981 благодарочка, что не забыл☝

Всегда пожалуйста ))

Спасибо большое )) я старался сделать видео максимально объемлющими, чтобы они давали цельное представление )

Спасибо на добром слове )

Спасибо ) буду рад, если поделитесь роликом )

Спасибо )

Спасибо за подсказку! Я пока использую Rx по многим причинам, во-первых Rx в целом кроссплатформенный) То есть его с тем же успехом можно и в RxSwift применять ) во-вторых он решает не только задачи многопоточности, но и другие, ну и в третьих корутины пока еще не набрали мощи массового применения и многое до сих пор написано на Rx, но планирую переходить да.

Я уже подзабыл это видео ) Но вообще спасибо, не знал)

Спасибо, дженерики еще не делал. Буду делать в основах

Рад что понравилось ) Буду очень рад если порекомендуете канал друзьям )

Да я бы посоветовал, да честно говоря некому) Когдато я ходил на курсы по Андроид разработке. Так вот, я пробовал советовать одногрупникам каналы. Ну или как минимум конкретные видео. Меня не особо слушали. Наверное каждому необходимо своё изложение. Но если у меня спросят, обязательно расскажу)

Ну можно в соц. сетях разместить ) вдруг заинтересует ) в любом случае, спасибо!)

Спасибо!)

Пожалуйста :)

CompositeDisposable dispose = new ...

Спасибо )

Рад, что помогло )

Подумаю над этим, спасибо )

Пожалуйста ) рад, что помогло )

Пожалуйста )

Пожалуйста :)

В каком это языке?))

@@MobileDeveloper American English check it out here ru-vid.com/video/%D0%B2%D0%B8%D0%B4%D0%B5%D0%BE-p0Utdnh4hg8.html

Спасибо )) да есть некая схожесть )

Спасибо!

Это невозможно )) что то видимо вы упускаете )

@@MobileDeveloper Да, вы правы он работает в main потоке, просто .subscribeOn(Schedulers.newThread()) - не работает, разбираюсь почему.

Может вы его где то не там прописываете?

@@MobileDeveloper class MainActivity : AppCompatActivity() { override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) setContentView(R.layout.activity_main) btnText.setOnClickListener() { Log.e("MyClick", "click click") } val dispose = dataSource() .subscribeOn(Schedulers.newThread()) // .observeOn(AndroidSchedulers.mainThread()) .subscribe({ btnText.text = "Next int $it" Log.e("TAG", "next int $it") Log.e("TAG", "current Thread $it" + Thread.currentThread().toString()) }, { }) } fun dataSource(): Observable { return Observable.create{ subscriber -> for (i in 0..100) { Thread.sleep(2000) subscriber.onNext(i); } } } } Тут просто негде сделать ошибку))

Проверьте тред внутри самого обсервабл

Рад что в тему :)

​@@MobileDeveloper поидее начинающие и не должны лезть сразу к сложным штукам, и научиться со временем, какнибудь. Но для таких нетерпеливых джунов как я например, каждый подробный ролик про хорошую библитеку - прям находка, спасибо!

Это не последний ) Позже начну цикл еще совсем для новичков

Да Котлин язык будущего )) спасибо )

Оу шит ))) ну да )

Спасибо. Клим Саныча регулярно слушаю очень умный мужик.

Спасибо большое!

Спасибо )

Антон Алябьев почему?)

Спасибо )

Пожалуйста ) рад, что помог ))

Спасибо большое!!

Некоторые библиотеки с ним конфликтуют. В Мокси даже есть заявка на поддержку Androidx. Ну и общее правило работает - не трогай ) перейду со временем.

Спасибо )

Спасибо большое ))

Вам спасибо!)

Отдельный респект ещё за эксперименты в видео как на 46:00 !)

Спасибо большое :)

@@MobileDeveloper Начал смотреть на днях ваш канал с этого видео, потому что готовлюсь к собеседованию. И хочу выразить благодарность, пока только в форме комментариев) По видео вот прям чувствую что разработчик, быстро набираете код, ориентируетесь в среде разработки ну и плюс грамотная речь с конкретными терминами. Такого и правда очень мало на ютубе. И общение наравне со зрителем, что особо радует) Ну и конечно же поздравляю с Новым годом) Желаю ещё больше энергии, желания творить и создавать крутые проекты! Респект за вклад в развитие IT!

@@danilstepanov4555 спасибо большое очень приятно ) Рад что канал помогает ) Если хотите помочь каналу, то репост видео будет лучшей помощью )

Скоро будет :)

Хахахах это настолько крутой вопрос, что я готов даже за него приз дать какой нибудь из своей коллекции )) Ну в голову пришло попросить написать на листочке или рассказать зачем нужны корутины если уже есть rx Java ) можно сразу два зайца убить )) и про подход и про потоки вс неблокирующие операции P.S. Вы из Москвы?

Mobile Developer Я из Украины. Объяснл. Писал. Рисовал. Спецом захерячил на гите сампл проект с реактивным подходом без ReactiveX. На голых обсерверах. Эффекта ноль.. Мы на юзаем реакт, при этом мы ходим в репозиторий за данными при любых изменениях состояния LifeCycleOwner - ов. И мы "не видим в этом ничего странного". А потом мы смеемся над анекдотами про идусов и их код) Вопрос по сути риторический. Скорее не вопрос даже, а крик души.

Ну ) да ) работает же )) тонкой оптимизацией редко кто занимается. То что оно там на каждый чих по 30 объектов создаёт это мало кого волнует. Rx очень удобная штука как дирижёр у оркестра. Но мы в своих проектах будем уходить в корутины + livedata

@@MobileDeveloper да... имеет смысл. Я уже не раз задумывался, стоит ли вообще использовать реакт при работе с котлином. Пулы потоков нам впринципе не нужны. Их можно заменить из коробки(корутинами). Обсервера у нас есть из коробки(наблюдаемые свойства), и в SDK( life data). Стрим-апи вроде как тоже есть. Но тут дилема. С одной стороны - не хочется подключать сторонние инструменты, когда есть подходящие из коробки. С другой - всетаки реакт в этом смысле по-мощьнее будет на сегодняшний день(ИМХО). А вообще - надо переходить на XAMARIN O_o Там C#. Он по-круче будет чем котлин с джавой(пусть даже с Reactive). Дык еще и кросс-платформенный)))

Просто я боюсь что мой голос в полной тишине очень быстро надоест )))

@@MobileDeveloper, вовсе нет!) голос приятный. А тишина помогает полностью сосредоточиться на материале, тем более что излагаете Вы отлично!!! надеюсь, мое мнение будет принято во внимание)

@@annaumova спасибо, я подумаю что с этим сделать ) Наверное, опрос проведу в группе в вк. Подписывайтесь туда, чтобы и ваше мнение было учтено )

А мне наоборот с музыкой больше нравится, она же фоном )

Спасибо ))

Библиотека называется так. Язык я всегда указываю в левом нижнем углу

Я сейчас очень редко играю ))

Спасибо ) очень непросто это видео делалось) но будут ещё части

Спасибо большое!)

Спасибо, видел про Java, но, к сожалению, примеры здесь на Котлин

Пожалуйста )

Ого )) вам спасибо)

Олды тут?)

Олды тут?)

Олды тут?)