Я подробно изучил документацию оператора Flowable.merge()
в RxJava, но не могу найти нужную мне информацию.
Мое понимание после некоторых экспериментов состоит в том, что дано n
в восходящем направлении.flowables F i , каждый из которых испускает значения в своем собственном потоке T i , оператор merge
гарантирует, что объединенный потокэти значения в сериализованном виде, так что нисходящий поток наблюдал их перед выпуском предыдущего.Эксперименты также говорят, что по умолчанию значение V i наблюдается потоком ниже по потоку в том же потоке T i , как это было
Это означает, что даже если merge
гарантирует, что нисходящий поток получает значения последовательно, он может наблюдать их в разных потоках.
Теперь возникает вопрос: гарантирует ли RxJava наблюдение зазначение происходит до наблюдения следующего значения?Будут ли видны все изменения, сделанные в памяти при наблюдении значения в T i , при наблюдении следующего значения в T j ?