Но ведь если  получен null вернется onComplete, нужен случай именно c null для продолжения цепочки)

null в rxjava2/3 нет

А вот еще такой вопрос, как объединить два сингла и один обвервабл, чтобы они шли в одной цепочки?

объединить это concat (в строгом порядке) либо merge (нет порядка)

Спасибо, поэксперементирую)))

Добрый день.
Подскажите как данный код может привести к крешу?
В настоящем коде вместо throw вызов метода который приводит к IllegalStateException иногда.

Всем привет)

Подскажите, у меня есть Observable, мне в самом начале (мб подписке?)
вручную поместить один onNext в самое начало цепочки.

startWith

к крешу может привести ошибка в секции subscribe:onNext. смотря какие там вычисления

ошибки в потоке пойдут в subscribe:onError. в данном случае с ними все ок, они просто печатаются

кажется разобрался, ошибка в крешлитиксе была только на одних устройствах (Vivo), похоже на них printStackTrace фиксируется как ошибка и попадает в крешлитикс

Всем привет, есть вопрос, как сделать эмит айтемов с задержкой, которую устанавливает предидущий айтем?

/class Segment(
   val startTime: Int,
   val duration: Int
)

fun main() {
   val segments = listOf(
       Segment(0, 1500),
       Segment(1500, 3000),
       Segment(4500, 450)
   )

   Observable.fromIterable(segments)
       .period { segment ->
           waitFor = segment.duration // здесь мы ставим задержку для следующего айтема
       }
       .subscribe { segment ->
           doSomeWork(segment.startTime) // нулевой айтем эмитится немедленно
       }
}

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

а чтобы первый был сразу, то немного многословнее: fromIterable.concatMap(v -> concat(just(v), just(v).delay(v.duration)).skipLast(1)) но проверить надо

Привет, читаю про RxBinding, там есть замечание про создаваемые Observable. что нужно явно отписываться.
1) Это касается Observable создаваемых click или вообще?
2) Есть ли для это какие нить умные указатели, которые сами отписываются при уничножение фрагмента или что то ещё?
3) В какой части жизненного цикла фрагмента/активности надо отписываться от View ?

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

Привет, читаю про RxBinding, там есть замечание про создаваемые Observable. что нужно явно отписываться.
1) Это касается Observable создаваемых click или вообще?
2) Есть ли для это какие нить умные указатели, которые сами отписываются при уничножение фрагмента или что то ещё?
3) В какой части жизненного цикла фрагмента/активности надо отписываться от View ?

zip?