Ottobus

Greenbus

OttoBus устарел

некого не слушай, подключи ивентБас и пуш все через него

Что значит "некого не слушай"??? Я лишь имел ввиду, чтобы он не хранил ссылку на активити

это значит никого не слушай, меня слушай :)

ребят, минутка оффтопа. Сегодня 1 сентября, кто -нибудь учится?)

и ещё осень началась (

не, нам ещё рано, через 3 года пойдем

ребят, минутка оффтопа. Сегодня 1 сентября, кто -нибудь учится?)

Я учусь

Я учусь

студент? уже чувствуется настрой на учебу?)

Слава богу нет)

студент? уже чувствуется настрой на учебу?)

Не, учусь терпению или тому, как объяснить рм что то, что проект - полнейшее ...овно и делать его я не буду

Любителям дженериков посвящается. Пишите дженерики правильно https://www.youtube.com/watch?v=H5WlE8BK5sI&index=27&list=PLYj3Bx1JM6Y7BKivc3eZwRUhWwBmbIFXg

public Observable<List<TestResult>> getTestResults(){ return query(SELECT( TestResult.COL_ID, TestResult.COL_QUESTIONS_COUNT, TestResult.COL_CORRECT_COUNT, TestResult.COL_SECTION_NAME ).FROM(TestResult.TABLE_NAME)).run().mapToList(TestResultMapper.MAPPER); }

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

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

ты Джейка не знаешь ? какие у него документации. ридми на гитхабе вот вся дока))

ты Джейка не знаешь ? какие у него документации. ридми на гитхабе вот вся дока))

блин, вот я не поленился и зашел на гитхаб. в первом же абзаце же написано! The BriteDatabase.createQuery method is similar to SQLiteDatabase.rawQuery except it takes an additional parameter of table(s) on which to listen for changes.

как можно юзать либу и даже не прочитать описание?

я это видел, но мне это дало ровно 0 инфы(

дальше написано This means that when you insert, update, or delete data, any subscribed queries will update with the new data instantly.

и третий раз еще ниже All insert, update, or delete operations must go through this object in order to correctly notify subscribers.

у меня query с селектом

я это видел, но мне это дало ровно 0 инфы(

вот это печально, значит надо английский подтягивать.. )

либа заточена на такое поведение. можно ли там сделать иначе - надо разбираться, я ее не юзал

вот это печально, значит надо английский подтягивать.. )

ага видимо, ну понятно что оно типо как rawQuery и принимает таблицу, на которой слушает изменения. что-то такое я понял из этого

SqlBrite's only responsibility is to be a mechanism for coordinating and composing the notification of updates to tables such that you can update queries as soon as data changes.

это вообще основное назначение либы - давать обновления. если нужен просто маппер - смотри на другие решения, будет удобнее имхо

Это чего тут теперь переводами занимаются?)))

SqlBrite's only responsibility is to be a mechanism for coordinating and composing the notification of updates to tables such that you can update queries as soon as data changes.

я свой обсервабл по запросу в сеть флатМапнул с sqlbrite вским и тогда onCompleted срабатывало, почему так не знаешь?

Это чего тут теперь переводами занимаются?)))

есть че перевести? ))

Денег мне переведите плиз)))

я свой обсервабл по запросу в сеть флатМапнул с sqlbrite вским и тогда onCompleted срабатывало, почему так не знаешь?

ну запрос в сеть завершился, вот ты и получил onCompleted

ну запрос в сеть завершился, вот ты и получил onCompleted

а как рулить этим всем, когда onCompleted, когда много OnNext ?

от чего это зависит?

то есть там где-то в операторах видимо onNext вызывается у сабскрайбера что ли?

а как рулить этим всем, когда onCompleted, когда много OnNext ?

http://rxmarbles.com/

а пробовали StorIO для обертки sqlite?

onComplete может не вызываться

http://rxmarbles.com/

всё это я видел, но не понял ((

это в зависимости от задачи и реализации

Это Hot and Cold observables

а пробовали StorIO для обертки sqlite?

я рассматривал storeIO или sqlbrite, в итоге выбрал Sqlbrite

http://rxmarbles.com/

играйся, наблюдай, читай туториалы по rx. еще полезно просто свои эксперименты ставить. разберешься. в двух словах все rx не объяснишь. если есть конкретный вопрос - отвечу

всё это я видел, но не понял ((

ну на этом сайте весьма все наглядно. разберись как эти диаграммы работают и намного легче станет

Это Hot and Cold observables

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

“Hot” and “Cold” Observables When does an Observable begin emitting its sequence of items? It depends on the Observable. A “hot” Observable may begin emitting items as soon as it is created, and so any observer who later subscribes to that Observable may start observing the sequence somewhere in the middle. A “cold” Observable, on the other hand, waits until an observer subscribes to it before it begins to emit items, and so such an observer is guaranteed to see the whole sequence from the beginning. In some implementations of ReactiveX, there is also something called a “Connectable” Observable. Such an Observable does not begin emitting items until its Connect method is called, whether or not any observers have subscribed to it.

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

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

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

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

Хорошая идея! надо так и сделать.

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

это всё понятно, как реализовать холодный?

Хорошая идея! надо так и сделать.

словами можно 10 раз прочитать и не понять. а на опыте гораздо быстрее разберешься

словами можно 10 раз прочитать и не понять. а на опыте гораздо быстрее разберешься

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

https://www.javacodegeeks.com/2015/03/hot-and-cold-rx-java-observable.html

вот с примерами

думаю у многих так. это от опыта зависит

а вот ещё скажите есть такие классы ConnectableObservable, Single, в чём особенность их реализации?

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

помоему так

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

1 раз сработает ?

Да помоему только один раз выдаст и завершится

Да помоему только один раз выдаст и завершится

у меня ообычные похоже тоже только 1 раз

ну ты поставь в конец publish или connectable

еще есть Completable

тоже удобная штука

https://www.javacodegeeks.com/2015/03/hot-and-cold-rx-java-observable.html

о спасибо, вот так понятнее когда на примерах)

слова ничего не стоят, главное КОД )))

ERROR: S client not available

еще есть Completable

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

@electrolobzik ты rx норм освоил на примерах тоже игрался ?

мне кажется,что даже играясь на примерах не совсем можно освоить rx

хотя после stream api заходит норм rx

в универе был курс по хаскелю, писали немного функциональщины. Но rx с функциональщиной похож только операторами.

а вот порядок выполнения обсервабл не до конца ясен скажем так

их жизненный цикл

@electrolobzik ты rx норм освоил на примерах тоже игрался ?

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

не понятно ещё почему везде используют обычный Observable, всякие ConnectableObservable вроде интереснее выглядят.

dj dczrb[ kb,f[ cvjnh. ghjcnst .pf.n

во всяких либах смотрю простые юзают

под капотом

не понятно ещё почему везде используют обычный Observable, всякие ConnectableObservable вроде интереснее выглядят.

чаще всего это просто не нужно.

а некоторые API появились позже чем либы

чаще всего это просто не нужно.

а ты в приложениях чаще всего обычные используешь?

например Completable и Single недавно сравнительно появились

а ты в приложениях чаще всего обычные используешь?

я сейчас всякие использую. Completable и Single часто очень удобны и позволяют избежать ошибок. с Observable гораздо проще иногда выстрелить себе в ногу

кстати где-то видел пишут что не стоит юзать Observable.create

лучше всякие just, deffer

Singl знаю в StorIO используется чтобы постоянно не получать обновления при изменении данныхх

почему?

что можешь сказать по этому поводу?

Раньше был простой и приходилось отписываться постоянно

что можешь сказать по этому поводу?

ну в общем случае это мне не понятно. в конкретных - мб

но нужны аргументы и контекст

с create сейчас разговор идет что не потокобезопасно вроде. и обсуждали asynccreate

совсем без create разве можно обойтись? не понимаю пока

с create сейчас разговор идет что не потокобезопасно вроде. и обсуждали asynccreate

а есть ссылка на обсуждение или статью?

интересно почитать

Singl знаю в StorIO используется чтобы постоянно не получать обновления при изменении данныхх

О! интересный момент. А как наоборот получать данные по обновлению? вот я создал обсервер subsribe вызвал туда передал сабскайбера и обсервабл начал сразу генерить данные. Как повторно заставить обсервабл данные генерить?

подписаться

.fromCallable вместо .create