Início / coding / Perguntas / 78206815
Accepted
syahiruddin
Asked: 2024-03-22 22:13:06 +0800 CST

Como recuperar um array no final de um observável sem usar toArray() em Angular/RxJS?

  • 772

Eu tenho um riched_sns$ observável que estou enriquecendo executando operações em cada item emitido usando concatMap e, em seguida, combinando os resultados em uma matriz usando toArray(). No entanto, estou curioso para saber se existe uma abordagem alternativa para obter o mesmo resultado sem usar toArray().

Aqui está meu código atual:

private enriched_sns$ = toObservable(this.sn_results).pipe(
  concatMap((results) => results as StreamNotificationResult[]),
  concatMap((notification) => {
    const user_id = notification.activities[0].actor.id;
    return zip(of(notification), this.read_user_data_service.readUserData(user_id));
  }),
  map(([notification, user]) => {
    return {
      notification,
      user: user,
    };
  }),
  toArray(),
);

Existe uma maneira de obter uma matriz de itens emitidos no final do observável sem recorrer a toArray()? Qualquer ajuda ou abordagens alternativas seriam muito apreciadas. Obrigado!

rxjs

1 respostas

  1. Best Answer

    O motivo pelo qual você precisa usar toArray()no seu exemplo é porque você está pegando o array emitido do seu sinal e depois emitindo cada elemento individualmente.

    Você poderia usar a forkJoinfunção para lidar com a assinatura de uma matriz de observáveis, em vez de concatMapemitir cada elemento, um de cada vez:

    private enriched_sns$ = toObservable(this.sn_results).pipe(
  concatMap((results: StreamNotificationResult[]) => forkJoin(
    results.map(n => this.read_user_data_service.readUserData(n.activities[0].actor.id).pipe(
      map(user => ({ notification: n, user }))
    ))
  )),
);

    Há uma diferença importante: forkJoinsubscrever todos os observáveis ​​ao mesmo tempo, e não um de cada vez. Se você precisar limitar a simultaneidade, você pode verificar o rxjs-etcpacote que possui uma forkJoinConcurrentfunção que permite especificar a simultaneidade:

    private enriched_sns$ = toObservable(this.sn_results).pipe(
  concatMap((results: StreamNotificationResult[]) => forkJoinConcurrent(
    results.map(n=> this.read_user_data_service.readUserData(n.activities[0].actor.id).pipe(
      map(user => ({ notification: n, user }))
    ))
  ), 1), // <-- limit to one inner subscription at a time
);

    Observe que o uso de zip/ ofnão é necessário. Você pode simplesmente adicionar um .pipeao seu observável interno e mapear a emissão para a forma desejada:

    private enriched_sns$ = toObservable(this.sn_results).pipe(
  concatMap((results: StreamNotificationResult[]) => results),
  concatMap(notification => {
    const user_id = notification.activities[0].actor.id;
    return this.read_user_data_service.readUserData(user_id).pipe(
      map(user => ({ notification, user }))
    );
  }),
  toArray(),
);
    • 1

relate perguntas