Поддерживает ли rx- java IO Scheduler порядок?

Question

Мне интересно, будет ли Schedulers.io() выполнять задачи в порядке вызывающего абонента.

public class SaveTest {

    @Inject
    private MyRepository myRepository;

    public void save()  {
        Observable.range(0, 20)
                .map(l -> new MyModel(l))
                .observeOn(Schedulers.io())
                .subscribe(myRepository::save);
    }
}

При вставке новых данных, даже если порядок не соблюдается, проблем нет. Но при обновлении ex:

    BankAccount account = new BankAccount();
    account.deposit(500);
    account.withdraw(50);

и каждая операция приводит к сохранению в реактивном потоке, порядок очень важен.

Мой вопрос: поддерживает ли IO Scheduler порядок?

Answer 1

Да, реактивный поток поддерживает порядок событий, даже если вы передаете события другому планировщику, подобному этому.

Внутренне события помещаются в очередь, и один потоковый рабочий выбирается планировщик (, как описано здесь ) выбирает их из очереди по порядку.