RXJS для синхронизации сетевого вызова

Question

Наше ионное приложение часто вызывает определенную веб-службу, и сервер выдает ошибки, когда один и тот же вызов выполняется параллельно.

Мы хотим убедиться, что вызовы синхронизированы. Как этого добиться в RXJS?

Observers(View1..n)=>Observable(User)=={apply control here?}==>NetworkCall(getUser())

Answer 1

Использовать карту concat для последовательных вызовов

concatMap (): проецирует каждое исходное значение в Observable, которое объединяется в выходной Observable, в последовательном порядке, ожидая завершения каждого из них перед объединением следующих * 1003. *

SendMsg(msgs: string[]) {

            msgs.map(msg=> this.SendMsgService.({setail: msg.description, userId: msguser}));
            from(msgCalls)  
                .pipe(
                    concatMap(res => res), 
                ).subscribe(() => { });
}