Los campos en mi caso se pueden finalizar (se ejecutaron acciones vinculadas a un campo). Cuando terminen, necesito actualizar 2 listas:

• campos ya ejecutados: cadena [] --> matriz simple
• restingFieldsToExecute: BehaviorSubject<string[]> --> sujeto de comportamiento, porque un .next necesita activar otra lógica. Esta lógica se puede activar en paralelo, pero quiero evitarlo porque hay un empalme dentro de esta lógica que puede comportarse incorrectamente en ese momento. (empalmando un índice, que se eliminó en la cadena paralela).

Entonces, cuando un campo necesita ser finalizado, llamo:

 this.finalize$.next(field);

Y la cadena finalize$ se ve así:

 this.finalize$.pipe( concatMap((field: string) => { return new Promise<void>((resolve) => { console.log('START', field); this.alreadyExecutedFields.push(field); const remainingFieldsToExecute = this.remainingFieldsToExecute$.value; remainingFieldsToExecute.splice(remainingFieldsToExecute.indexOf(field), 1); this.remainingFieldsToExecute$.next(remainingFieldsToExecute); console.log('END', field); resolve(); }); }), ).subscribe(() => { });

Pero por alguna razón, cuando 2 llamadas finalize$.next suceden una después de la otra, concatMap no espera la promesa de la anterior. Además, cuando traté de poner un tiempo de espera alrededor del registro END y la resolución, no espera la resolución anterior.

Lo que sí funciona en mi caso es, en lugar de usar un concatMap, usar un setInterval con una bandera, que bloquea la parte del código donde se actualizan las listas.

Pero, ¿cómo se puede hacer esto de una mejor manera? O de forma correcta con o sin tubos concat.