前言

昨天介紹 Effect-TS 時(shí)，有小伙伴問我：和 RxJS 的語法很像，他們有什么區(qū)別？

1. 核心概念

RxJS 是一個(gè)基于 Observables 的庫，用于處理異步和基于事件的編程。它通過響應(yīng)式編程范式，讓開發(fā)者能夠以聲明式的方式管理復(fù)雜的數(shù)據(jù)流和事件，下面是幾個(gè)核心概念

• Observable：Observable 是 RxJS 的核心，表示一個(gè)可以隨時(shí)間發(fā)出多個(gè)值的數(shù)據(jù)流。你可以將其想象成一個(gè)“可訂閱的管道”，通過它可以接收數(shù)據(jù)。

import { Observable } from 'rxjs';

const observable = new Observable(subscriber => {
  subscriber.next(1);
  subscriber.next(2);
  setTimeout(() => {
    subscriber.next(3);
    subscriber.complete();
  }, 1000);
});

• Observer：Observer 是訂閱 Observable 的對(duì)象，包含 next、error 和 complete 方法，用于處理 Observable 發(fā)出的值、錯(cuò)誤和完成狀態(tài)。
• Subscription：Subscription 是訂閱 Observable 后返回的對(duì)象，用于管理訂閱狀態(tài)，比如取消訂閱

const subscription = observable.subscribe({
  next: value => console.log(value),
  error: err => console.error(err),
  complete: () => console.log('Completed')
});

// 取消訂閱
subscription.unsubscribe();

• Operators：RxJS 提供了豐富的操作符（如 map、filter、mergeMap 等），用于轉(zhuǎn)換和操作數(shù)據(jù)流

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

of(1, 2, 3, 4)
  .pipe(
    filter(x => x % 2 === 0),
    map(x => x * 2)
  )
  .subscribe(x => console.log(x)); // 輸出 4, 8

2. 常用操作符

RxJS 的操作符是其強(qiáng)大功能的核心，以下是幾個(gè)常用的操作符：

• map：對(duì)數(shù)據(jù)流中的每個(gè)值進(jìn)行轉(zhuǎn)換。
• filter：過濾符合條件的值!
• mergeMap：將一個(gè) Observable 映射為另一個(gè) Observable，并將結(jié)果展平。
• debounceTime：延遲發(fā)出值，常用于處理用戶輸入防抖!

import { fromEvent } from 'rxjs';
import { debounceTime, map } from 'rxjs/operators';

const input = document.querySelector('input');
fromEvent(input, 'input')
  .pipe(
    debounceTime(300),
    map(event => event.target.value)
  )
  .subscribe(value => console.log(value));

3. 實(shí)際應(yīng)用場景

• 表單輸入防抖：通過 debounceTime 減少不必要的 API 請(qǐng)求。
• 實(shí)時(shí)數(shù)據(jù)處理：如 WebSocket 數(shù)據(jù)流，通過 mergeMap 和 filter 處理復(fù)雜邏輯。
• 異步任務(wù)協(xié)調(diào)：使用 forkJoin 或 combineLatest 組合多個(gè)異步請(qǐng)求!

import { forkJoin, of } from 'rxjs';
import { delay } from 'rxjs/operators';

const source1 = of('Hello').pipe(delay(1000));
const source2 = of('World').pipe(delay(2000));

forkJoin([source1, source2]).subscribe(([res1, res2]) => {
  console.log(`${res1} ${res2}`); // 輸出 "Hello World"
});

最后

學(xué)習(xí)完之后，雖然在語法上頗有相似之處，但是給我的第一感覺：Effect-ts 的設(shè)計(jì)理念是基于副作用思想的開發(fā)范式，而 Rx.js 脫胎于響應(yīng)式編程思路的開發(fā)范式，另外 Rx.js 主打的是處理異步事件流，而 Effect-ts 主打的是比 TypeScript 更安全的類型推理！

官網(wǎng)：https://rxjs.dev/