что рано или поздно это произойдет

ну там че. сразу буду все во flowable пихать

:D

Не знаю почему,но до перехода на rx2 почти не юзал Single и Completable

мб потому, что некоторые операторы возвращают Single или Completeable теперь?

Не

как они могут не знать?

ну при отписке не происходит вызова onCompleted() или onError() только что проверил.

ну на самом деле сингл удобнее сделали. убрали не нужный колбэк onComplete

или onnext

не помню точно, но там должен быть метод doOnUnsubscribe

у последовательности

мб это поможет

На самом деле,у вас какое-то гавно с rx

Сабжекты почти всегда зло

а как без них?

На самом деле,у вас какое-то гавно с rx

почему? если не учитывать что от них надо отписываться

а как без них?

Довольно легко

Довольно легко

Ну вот. Смотри. У меня есть плеер. Он что-то там играет. Меняются треки, меняются плейлисты. Как мне сливать, например, событие "играет трек номер n"?

Было неплохое выступление на русском на тему рх и сабжектов

Было неплохое выступление на русском на тему рх и сабжектов

на ютубе есть?

И там было что-то вроде 1) не используйте сабжекты 2) даже если вы думаете,что вам нужны сабжекты,вы ошибаетесь 3) если вы все равно думаете что они вам нужны,смотрите предыдущий пункт

Было неплохое выступление на русском на тему рх и сабжектов

+1

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

ну сабжекты это удобно)

иногда

Удобно в какой-то момент чтобы наляхать

Удобно в какой-то момент чтобы наляхать

так что в итоге то? Как такую задачку без сабжектов на рх решить?

а про connectableObservable ничего не было сказано?

тож в какой то степени сабжект

А потом в какой-то момент все начинает идти не так, и получается мутант из сабжектов

тож в какой то степени сабжект

Неправильный ход мыслм

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

Абсолютно неверный

ну окей, а как было бы правильно?

Датчик имеет листнер?)

не для этих вещей rx?

Абсолютно неверный

а какой верный?

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

Hot observable != Subject

да блин

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

Окей

Смотри у тебя есть датчик

да

Например он дает тебе возможность повесить листнер

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

В этом случае самое галимое решение - повесить листнер и из него долбить в сабжект

я не понимаю о каком листенере ты говоришь

Интервал вызываешь у обзервабла

Hot observable != Subject

ну конектэбл обсервбл не совсем же hot.

Во флетмепе идешь на сервер

Интервал вызываешь у обзервабла

эт как?

Надо раз в 30 мс ходить Observable.interval(30, timeunit.ms)

По памяти

ну конектэбл обсервбл не совсем же hot.

Сабжект - выродок на стыке фрп и императивщины

Надо раз в 30 мс ходить Observable.interval(30, timeunit.ms)

и эта штука будет дергать next() у Observable ?

Неудобно с телефона,но вот статейка мелкая http://tomstechnicalblog.blogspot.ru/2016/03/rxjava-problem-with-subjects.html?m=1

Заставляете меня идти за ноутом

Ну ладно

The Interval operator returns an Observable that emits an infinite sequence of ascending integers, with a constant interval of time of your choosing between emissions.

типо ты такое предлагал? Observable.interval(30, TimeUnit.SECONDS, Schedulers.io()) .map(tick -> messageService.getRecentMessages()) .subscribe(messages -> { // the subscriber is called with List<Message> every time // the remote service is polled for (Message message : messages) { log.info(message.toString()) } })

блин)

да уж, такое мне точно непривычно)

ну блин,чувак,э

это не императивщина

ыы

ERROR: S client not available

уж прости

надо подумать

спасибо тебе!

это лучше чем

просто голову ломать надо Rxом,а не пытаться в привычной манере писать

вот

https://www.youtube.com/watch?v=9Y6EZPxXxYk

про сабжекты примерно на 9 минуте

https://www.youtube.com/watch?v=9Y6EZPxXxYk

Спасибо. Интересный доклад

Чуваки есть ли среди нас комрад Дмитрий Полищук? Автор этого видео. https://www.youtube.com/watch?v=W15ILDe56PQ

Что делать, если мне нужен BehaviourSubject? Например в случае модели, которая хранит последний актуальный кусок данных, который нужен для нескольких экранов?

просто голову ломать надо Rxом,а не пытаться в привычной манере писать

Доброе утро всем!!! Кто знает как сделать chain запрос на сервер? Пример запроса: getToken() -> getPersonNumber(token) personNumber -> getUserInfo(personNumber)

api.getToken() .flatMap(token -> api.getPersonNumber(token)) .flatMap(personNumber -> api.getUserInfo(personNumber)) .subscribe(userInfo -> doSomething())

Ребят подскажите, в студии есть функционал который показывает результат кода без запуска эмулятора. Просто при работе с переменными?

Юнит тест написать можно на метод

Можешь нажать Ctrl + Shift + A и ввести "Groovy console"

Там пишешь и исполняешь код

Исполнять по Ctrl+Enter

Комрады. Как сверять 2 инстанса Path на equals?

ПО сути они копия друг друга.

Второй просто чуток двигался. Но один был создан через другой

Вопрос не актуален

кто хорошо знает ретрофит

у меня xml вот так выглядит

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

вот так написал это правильно?https://gist.github.com/yer9ali/c97cc9e20e032f12210665be8e091ef8#file-rows-L3

вот так написал это правильно?https://gist.github.com/yer9ali/c97cc9e20e032f12210665be8e091ef8#file-rows-L3

Проверь.

Скажите как вы форматируете код, чтобы он читабельно смотрелся в телеграме?

Вот так: `