сам охуел как гибко вышл

ну спасибос, я тут невъебенно обсерваблы схуевертил все четко на операторах

мужик епта

я тока не вкуриваю что с backpressure делать пока

но это если начинаешь zip делать

а как оно вообще случается не пойму?

это типо обратная связь

в буферах там

итд

надо матчасть покурить

Observable .zip(qbCustomObjectManager.getSections(), sectionsDao.getSections(), (sectionsServer, sectionsDb) -> { if(sectionsServer != null) { return sectionsServer; } return sectionsDb; }) .flatMap(sectionsResult -> Observable.combineLatest(sectionsDao.replace(sectionsResult), Observable.just(sectionsResult), (aLong, sections) -> sections)) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(listObservable -> { Log.d("DEBUG", "sections"); });

бля

пох

один хуй гавно

хоть и кавычки

ну на операторах нормал получилось

а ты типо кеш делал? сервак/бд?

ну типо

если иннет выключен то с бд брать

ну довольно туповатый кэш

я где-то на медиуему вроде видел охрененное красивое решение для этого

я только не знаю как сделать протухание, чтобы из кэша бралось определенное время

там надо if а функциональщина не позволяет это делать или я не знаю как

там сначала HEAD делается на сервор, сверяется ETag, если обнова то выгружается и кладется в бд, дальше уже всегда чтение из бд

там надо if а функциональщина не позволяет это делать или я не знаю как

flatMap/map

хм а точно

один хуй гавно

http://collabedit.com/pq88t ?

а внутри функции мапы вызвать метод который узнает протухло или нет

http://collabedit.com/pq88t ?

не работает(

а ещё такой вопрос по rx. Я видел что существуют холодные и горячие обсерваблы. Вот холодные типо не сработают пока никто не подписан. Но я не пойму как тогда горячие делать, т.е. чтобы сразу срабатывали?

ща запилю

сек

Дядь

помоги

посонам

это кто? джедай rx ?

йода

йода

уже библитекой для времени и дат занято имя

Вот ссылка - https://github.com/Gordey/Code/issues/1

Вот ссылка - https://github.com/Gordey/Code/issues/1

так че там? надо dist обнулить в ACTION_MOVE?

Именно в условии

в ифе чтоле?

да if(Math.round(dist) >= oneStepVolumeHeight)

так обнуляется же

ниже

ACTION_MOVE вроде срабатывает каждый раз когда ты палец двигаешь по экрану

о

Че подсказать?)

про горячие холодные

Че подсказать?)

говорят ты йода Rx

горячие -- Subject и ConnectableObservable

не йода нихера)

не йода нихера)

мой песдюк

ээ

Subject ?

Subject да

Subject зло вроде

чем не горячий

ну на мобиусе Матвей сказал что гавно, значит гавно

ну ок) видимо горячее зло)

да я тоже там был)

ты помнишь почему гавно-то?)

потому что они нарушают функциональщину реактивщину

они для того чтобы соединить императив и функциональщину

а типо чаще всего есть способ обойтись

ну он по крайне мере считал так

ну если есть то конечно лучше без них

если работаешь на старом проекте, без них довольно тяжело

а это

вот я основую вещь не пойму

смотри мы создаем обсервабл

а так тогда пример "нормальных" горячих -- это Connectable

сабскрайбимся он сработал и всё, больше не юзабелен ?

грубо говоря как заставить обсервабл много раз срабатывать

там же все эти onNext есть которые на это расчитаны я так понимаю

а как делаешь? через just?

вообще обзервабл многоразовый, вот сабскрипшн после отписки больше нет

ну смотри, каждый запрос данных, это грубо говоря создание обсервабла и подписка на него и его срабатывание

бля, как же я от жизни отстал со сраным менеджментом

создавай обзерваблы через .defer или fromCallable

Observable .zip(qbCustomObjectManager.getSections(), sectionsDao.getSections(), (sectionsServer, sectionsDb) -> { if(sectionsServer != null) { return sectionsServer; } return sectionsDb; }) .flatMap(sectionsResult -> Observable.combineLatest(sectionsDao.replace(sectionsResult), Observable.just(sectionsResult), (aLong, sections) -> sections)) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(listObservable -> { Log.d("DEBUG", "sections"); });

вот грубо говоря так. Каждый скажем клик по кнопке выполняет весь этот код, т.е. новый обсервабл создается. Это же не тру вэй?

я новичек в rx(

и чууствую что делаю какое-то гавно не трушное(

бля, как же я от жизни отстал со сраным менеджментом

хреново, не хочу никогда уходить в менеджмент, лучше писать код. Идти в солюшен архитекторы

хреново, не хочу никогда уходить в менеджмент, лучше писать код. Идти в солюшен архитекторы

там бабки(

плюс я попиздеть и ебалом поторговать любитель

https://habrahabr.ru/company/e-Legion/blog/307098/

ахаха=)

что там?

@lion4ik А что не так с кодом?

ну типа по нажатию происходит вся вот эта цепочка?

@lion4ik А что не так с кодом?

ну смотри при клике он каждый раз вызывается. Значит каждый раз обсервабл создается и сабскрайбится? так должно быть?

ну да

может как-то нужно 1 раз создать эту цепочку и типо что-то сделать чтобы она емитила резалт?

по клику типо емитила очередной резалт

но не создавалась заново