RxJS技术问询：减少映射表达式操作符数量及数据结构转换

Got it, let's streamline this RxJS flow while getting exactly the data structure you need. The key here is combining array transformations with RxJS operators efficiently to cut down on unnecessary steps.

Option 1: Get the entire transformed array as a single emission #

If you just need the full array of mapped countries (not individual object emissions), you can do this in a single map operator—no need for pluck or mergeMap:

import { of } from 'rxjs';
import { map } from 'rxjs/operators';

const fromDb$ = of({ Result: { Countries: [{ ISOCode: 1, Name: 'aaa' }, { ISOCode: 2, Name: 'bbb' }] } });

const transformedCountries$ = fromDb$.pipe(
  map(data => 
    data.Result.Countries.map(country => ({
      name: country.Name,
      value: country.ISOCode
    }))
  )
);

// Emits: [{ name: 'aaa', value: 1 }, { name: 'bbb', value: 2 }]

This works because we're using JavaScript's native Array.map inside RxJS's map operator to transform each country object directly. It's concise and avoids extra operators.

Option 2: Emit each transformed country object individually #

If you need to turn the array into a stream of individual objects (like your original approach with mergeMap + of), we can simplify this using switchMap combined with from (instead of of(...array)):

import { of, from } from 'rxjs';
import { switchMap, map } from 'rxjs/operators';

const fromDb$ = of({ Result: { Countries: [{ ISOCode: 1, Name: 'aaa' }, { ISOCode: 2, Name: 'bbb' }] } });

const countryStream$ = fromDb$.pipe(
  switchMap(data => from(data.Result.Countries)), // Converts array to observable stream
  map(country => ({
    name: country.Name,
    value: country.ISOCode
  }))
);

// Emits first: { name: 'aaa', value: 1 }, then: { name: 'bbb', value: 2 }

Why this is better:

• from is designed specifically to convert arrays (and other iterables) into observable streams, making it cleaner than spreading the array into of.
• We've cut down the number of operators compared to your original approach (no pluck needed since we directly access data.Result.Countries in switchMap).

Both approaches are more readable and efficient than chaining multiple unnecessary operators. Pick the one that fits whether you need the full array or individual emissions!

内容的提问来源于stack exchange，提问作者Royi Namir