Да точно, спасибо)

Что "Точно" если он не прав

Смотрим тест, пишем себе и радуемся

Что во флэтмапе прилетают все подписки разом

в конкате ПОСЛЕДОВАТЕЛЬНО

после завершения одной прилетает вторая

Расскажут тут мне господа что конкат == флэтмапу только порядок не тот

Киньт код плиз

public class Test {

   private Scheduler sleepScheduler;
   @org.junit.Test
   public void qqq() {
       sleepScheduler = Schedulers.from(Executors.newFixedThreadPool(15));

       System.out.println("Start flatmap test");
       Observable.just(1,2,3,4)
               .flatMapCompletable(integer -> save(integer))
               .subscribeOn(Schedulers.single())
               .blockingAwait();
       System.out.println("Start concatmap test");
       Observable.just(1,2,3,4)
               .concatMapCompletable(integer -> save(integer))
               .blockingAwait();

   }
   public Completable save(Integer iii) {
       return Single.just(iii)
               .observeOn(sleepScheduler)
               .flatMapCompletable(i -> {
                   System.out.println("Thread Sleep+ " + Thread.currentThread().getName());
                   Thread.sleep(1000);
                   System.out.println("Thread Unsleep+ " + Thread.currentThread().getName());
                   return Completable.complete();
               });
   }


}

Спасибо

проверяйте doOnSubscribe в save()

когда он вызывается у флэтмапа

а когда конкатом

фи такое писать.

Огорчен я сударь

а ты в save поставь для каждого свой поток и задержки на рандоме)

ну так я про то как испускает  флэтмап не спорю, а то что он последовательный - спорю)

так он НЕ последовательный, а ждет завершения ВСЕХ входящих, коряво написал мб)