概要

非同期処理は現代のアプリケーション設計において避けられない構造であり、
Promise、async/await、callback、さらにはEventEmitterやWebSocketなど、
多様な「時間に依存した流れ」が日々のコードを複雑にしている。

Rx（Reactive Extensions） は、その複雑さを**「ストリーム」という抽象で制御可能にするパラダイムである。
本稿では、Rxの思想・構造・背景を明快に整理し、なぜ「ただの非同期ライブラリ」ではなく設計哲学**なのかを明らかにする。

1. Rxとは何か？：宣言的・構造的・非同期なストリーム制御

「Rxは、イベントやデータの非同期的な流れを、関数的に合成し、宣言的に制御するための抽象である」

Rxの核となる型は Observable。
これは「未来の複数の値」をストリームとして扱い、以下を可能にする：

遅延評価
非同期イベントの合成
時間に基づく処理の制御（debounce, throttle）
エラー/キャンセル処理の統一

2. Rxの背景：pull vs pushの思考法

モデル	概要	例
pull型	消費者が必要なときに値を取りに行く	`for` / `Promise` / `Iterator`
push型	生産者が勝手に値を送りつけてくる	`EventEmitter` / `WebSocket` / `setInterval`

Rx = push型をpull的に制御可能にする抽象構造

3. Observableの基本構造

import { Observable } from 'rxjs'

const observable = new Observable<string>((subscriber) => {
  subscriber.next('A')
  subscriber.next('B')
  subscriber.complete()
})

observable.subscribe({
  next: (v) => console.log(`Received: ${v}`),
  complete: () => console.log('Done')
})

Observable = ストリームそのもの
Subscriber = 観測者（Observerパターン）
.next() = 値を発行
.complete() = 終了通知

4. Rxが解決する実務的な非同期の複雑さ

✅ 連続的な非同期イベント

// EventEmitterやaddEventListenerなど、永続する非同期
fromEvent(button, 'click')
  .subscribe(() => console.log('Clicked'))

✅ Promiseでは表現できない「キャンセル可能」なストリーム

const observable = interval(1000)

const sub = observable.subscribe(console.log)

// 5秒後にキャンセル
setTimeout(() => sub.unsubscribe(), 5000)

✅ 入力の合成とタイミング制御

fromEvent(input, 'input')
  .pipe(debounceTime(300))
  .subscribe(() => search())

→ ユーザーの連続入力を debounce して検索APIを叩くような、UIの快適性と最適化の両立が容易に

5. 宣言的なストリーム思考の強み

Rxを導入すると、以下のような設計的利点が得られる：

コールバック地獄からの解放
明示的な流れの構成（map → filter → switchMap …）
非同期の 構造的合成（複数ストリームのmerge, zip）
イベント処理・非同期IO・UIイベントが同じ抽象で統一できる

よくある誤解と対策

❌ RxはPromiseの置き換えでしょ？

→ ✅ Rxは「複数値を制御する抽象」であり、単一値のPromiseとは別軸

❌ RxJSはオーバーエンジニアリングでは？

→ ✅ シンプルな非同期には不要。だが状態・合成・制御の複雑さが増すほど威力を発揮

❌ 学習コストが高い

→ ✅ 事実。ただし得られる設計上の恩恵（キャンセル、合成、構造）は非同期を扱うすべてのレイヤーで重要

結語

Rxとは、単なる非同期ツールではない。
**「非同期をストリームとして捉え、構造的・宣言的に制御する思想」**である。

時間を含む「動的な流れ」に名前と構造を与え
UIもIOもイベントもすべて「ストリーム」として再定義し
設計の分断を乗り越えて、抽象による秩序を構築する

リアクティブ思考とは、
“非同期と状態のカオスに対し、ストリームという秩序をもって制御を取り戻すための設計哲学である。”