Каковы гарантии параллелизма для Flowable.merge () - PullRequest
0 голосов
/ 07 марта 2019

Я подробно изучил документацию оператора Flowable.merge() в RxJava, но не могу найти нужную мне информацию.

Мое понимание после некоторых экспериментов состоит в том, что дано n в восходящем направлении.flowables F i , каждый из которых испускает значения в своем собственном потоке T i , оператор merge гарантирует, что объединенный потокэти значения в сериализованном виде, так что нисходящий поток наблюдал их перед выпуском предыдущего.Эксперименты также говорят, что по умолчанию значение V i наблюдается потоком ниже по потоку в том же потоке T i , как это было

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

Теперь возникает вопрос: гарантирует ли RxJava наблюдение зазначение происходит до наблюдения следующего значения?Будут ли видны все изменения, сделанные в памяти при наблюдении значения в T i , при наблюдении следующего значения в T j ?

...