RxJS5与延时观测值组合的高级示例

import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/of';
import 'rxjs/add/observable/interval';
import 'rxjs/add/operator/delay';
import 'rxjs/add/operator/mergeMap';
import 'rxjs/add/operator/take';

// 创建一个延时观测值
const delayedValues = Observable.of('Value 1', 'Value 2', 'Value 3')
  .delay(2000); // 延迟2秒

// 创建一个定时观测值
const intervalValues = Observable.interval(1000)
  .take(3); // 只取前3个值

// 组合延时观测值和定时观测值
const combinedValues = delayedValues.mergeMap(delayedValue =>
  intervalValues.map(intervalValue => `${delayedValue} - ${intervalValue}`)
);

// 订阅组合后的观测值
combinedValues.subscribe(value => console.log(value));