👻Hello World/📔NEON WIKI/
📒流合并
Search
📒

流合并

在RxJS中，可以使用一些操作符来合并多个Observable发出的数据流，从而形成一个新的Observable。以下是一些RxJS中用于合并数据流的操作符：
  1. concat操作符
concat操作符将两个或多个Observable的数据流合并成一个Observable。它会先发出第一个Observable中所有的数据，然后再按顺序发出后续Observable中的所有数据。例如：
Copy code
import { concat, of } from 'rxjs';

const source1 = of('Hello');
const source2 = of('World');
const example = concat(source1, source2);
example.subscribe(val => console.log(val)); // 输出: 'Hello', 'World'
  1. merge操作符
merge操作符将多个Observable发出的数据流合并成一个Observable。它会同时订阅并发出所有Observable发出的值，而不保证顺序。例如：
Copy code
import { merge, interval } from 'rxjs';

const source1 = interval(1000);
const source2 = interval(2000);
const example = merge(source1, source2);
example.subscribe(val => console.log(val)); // 输出: 0, 0, 1, 1, 2, 2, ...
  1. forkJoin操作符
forkJoin操作符接收一个Observable数组作为参数，并等待所有Observable都发出一个值，然后将它们合并成一个数组，并将其作为单个值发出。例如：
Copy code
import { forkJoin, of } from 'rxjs';

const source1 = of('Hello');
const source2 = of('World');
const example = forkJoin([source1, source2]);
example.subscribe(val => console.log(val)); //输出: ['Hello', 'World']
  1. zip操作符
zip操作符接收多个Observable作为参数，并将它们发出的值组合成一个数组，然后将该数组作为单个值发出。它会等待所有Observable都发出一个值，然后再发出组合后的值，发出的值数量取决于最短的Observable。例如：
Copy code
import { zip, of } from 'rxjs';

const source1 = of('Hello');
const source2 = of('World');
const example = zip(source1, source2);
example.subscribe(val => console.log(val)); // 输出: ['Hello', 'World']
通过使用这些合并操作符，您可以将多个数据流合并为一个。这对于需要从多个源中聚合数据或订阅多个数据流的情况非常有用。
 

merge 和 forkJoin 的区别

merge和forkJoin是两种不同的合并Observable的操作符:
  1. merge是用于同时处理多个Observable的操作符，可以将多个Observable的输出合并为单个输出。当有任何一个源Observable发出值时，merge就会把这个值输出，不需要等待其他的Observable。
  1. forkJoin是用于等待多个Observable都发出一个(仅最后一个)值，然后将它们合并到一个数组中并返回。只有当所有的源Observable都完成时，forkJoin才会发出值。因此，使用forkJoin，您可以等待异步操作完成，并收集它们的结果。
以下是一个展示两者区别的示例：
Copy code
import { forkJoin, interval, merge, of } from 'rxjs';
import { delay, take } from 'rxjs/operators';

const stream1$ = interval(1000).pipe(take(3));
const stream2$ = interval(2000).pipe(take(2));

// merge将即时收到observable流的值，而不进行等待
const merged$ = merge(stream1$, stream2$);
merged$.subscribe(console.log);
// 输出:
// 0
// 0
// 1
// 2
// 1

// forkJoin等待所有observable流都发出值后返回数组
const forked$ = forkJoin([stream1$, stream2$]);
forked$.subscribe(console.log);
// 输出: [[2,1]]
在上述代码中，我们创建了两个Observable，一个会在1秒、2秒、3秒后每隔1秒发出一个值，另一个会在2秒和4秒后每隔2秒发出一个值。使用merge操作符将两个Observable的输出合并为单个输出，因为merge输出是即时的，它会将每个Observable的值立即合并到一个流中。使用forkJoin操作符等待所有Observable都发出值之后，将值存储为数组返回，因为forkJoin只会在所有源Observable都完成之后发出值。
总的来说，merge用于同时处理多个源Observable的值，而forkJoin用于等待多个源Observable完成并收集它们的值。
 

combineLatest

combineLatest是 RxJS 中的一个操作符，它可以组合多个 Observables 中的最新值，并将这些值组合成一个数组。
combineLatest操作符将发送数组，其中包含与每个传递的 Observable 的最新值对应的值。每当任何一个源 Observable 发出新值时，都会组合这些值并将它们发出。以下是一个示例：
import { combineLatest, of } from 'rxjs';

const source1$ = of('a', 'b', 'c');
const source2$ = of(1, 2, 3, 4);

const combined$ = combineLatest([source1$, source2$]);

combined$.subscribe(([source1Value, source2Value]) => {
  console.log(`${source1Value} ${source2Value}`);
});

// 输出：
// 'a 1'
// 'b 1'
// 'b 2'
// 'c 2'
// 'c 3'
// 'c 4'
在上述代码中，我们使用of创建两个 Obervables，一个包含三个字符 'a'、'b' 和 'c'，另一个包含数字 1、2、3 和 4。使用combineLatest操作符将两个 Observable 组合在一起，当源 Observables 中任何一个 Observable 发出新值时，将其绑定到组成的数组，并将该数组传递给 combined$ 的订阅函数。
combineLatest 可以同时处理多个源 Observable 的最新值，并将它们组合成一个数组。只有在所有 Observable 都至少发出过一次值之后，才会开始组合项目，并在任何 Observable 发出值时更新。因此，这与 forkJoin 有所不同，后者只要所有 Observable 都发送了完整的值集合，就会组合值。
 

mergeAll 和 combineLatest

mergeAll 和 combineLatest 都是 RxJS 中的操作符，具有不同的功能：
  • mergeAll 将一个高阶 Observable 转换成一个一级 Observable，将高阶 Observable 内部的所有 Observable 并列地合并成一个输出 Observable。也就是说，无论是哪个 Observable 发出项，它们都会被合并到输出 Observable 中。这个操作符通常用于处理多个流的情况，特别是在处理并发请求的情况下，可以将请求并发发出，最后将它们的结果合并到一个流中以获得最终结果。
  • combineLatest 则是将多个 Observable 中的最新项组合起来，当所有 Observable 都至少有一个发射值时，输出一个由每个 Observable 发射的最新值构成的数组。每当其中任何一个 Observable 发出新的值，它就会重新计算这些值，并将新的数组发出。这个操作符通常用于需要同时获取多个事件的最新值，以作为表单或者其他内部组件的输入。
在通常情况下，如果需要处理多个流并获得最终结果，则需要使用 mergeAll 操作符，如果需要同时获取多个事件的最新值，则需要使用 combineLatest 操作符。
 

总结

combineLatest 不会等所有的流都发出值，他只要其中某一个发出了值，就会开始组合输出。
forkJoin 要等所有流都发出值，才会输出。
 
 
Copyright 2022 leonbeau