実践的なユースケース

この章では、RxJSの結合オペレーターを活用した実践的なユースケースを紹介します。 UI操作やAPI通信など、実際のアプリケーション開発に役立つシナリオを通じて、理解を深めましょう。

フォーム入力の検証とAPIリクエスト

combineLatestを使用して複数のフォーム入力を検証する例です。

import { combineLatest, fromEvent } from 'rxjs';
import { map, debounceTime, startWith } from 'rxjs';

// フォームUI作成
const formContainer = document.createElement('div');
formContainer.innerHTML = '<h3>ユーザー登録フォーム:</h3>';
document.body.appendChild(formContainer);

// 名前入力
const nameLabel = document.createElement('label');
nameLabel.textContent = '名前: ';
formContainer.appendChild(nameLabel);

const nameInput = document.createElement('input');
nameInput.type = 'text';
nameInput.id = 'name';
nameInput.style.marginBottom = '10px';
nameInput.style.marginLeft = '5px';
formContainer.appendChild(nameInput);
formContainer.appendChild(document.createElement('br'));

// メール入力
const emailLabel = document.createElement('label');
emailLabel.textContent = 'メール: ';
formContainer.appendChild(emailLabel);

const emailInput = document.createElement('input');
emailInput.type = 'email';
emailInput.id = 'email';
emailInput.style.marginBottom = '10px';
emailInput.style.marginLeft = '5px';
formContainer.appendChild(emailInput);
formContainer.appendChild(document.createElement('br'));

// パスワード入力
const passwordLabel = document.createElement('label');
passwordLabel.textContent = 'パスワード: ';
formContainer.appendChild(passwordLabel);

const passwordInput = document.createElement('input');
passwordInput.type = 'password';
passwordInput.id = 'password';
passwordInput.style.marginLeft = '5px';
formContainer.appendChild(passwordInput);
formContainer.appendChild(document.createElement('br'));

// 送信ボタン
const submitButton = document.createElement('button');
submitButton.textContent = '登録';
submitButton.disabled = true;
submitButton.style.marginTop = '15px';
submitButton.style.padding = '8px 16px';
formContainer.appendChild(submitButton);

// バリデーションメッセージ
const validationMessage = document.createElement('div');
validationMessage.style.marginTop = '10px';
validationMessage.style.color = 'red';
formContainer.appendChild(validationMessage);

// 名前の検証
const name$ = fromEvent(nameInput, 'input').pipe(
  map((event) => {
    const value = (event.target as HTMLInputElement).value.trim();
    return {
      value,
      valid: value.length >= 2,
      error: value.length < 2 ? '名前は2文字以上入力してください' : null,
    };
  }),
  startWith({
    value: '',
    valid: false,
    error: '名前は2文字以上入力してください',
  })
);

// メールの検証
const emailRegex = /^[^\s@]+@[^\s@]+\.[^\s@]+$/;
const email$ = fromEvent(emailInput, 'input').pipe(
  map((event) => {
    const value = (event.target as HTMLInputElement).value.trim();
    return {
      value,
      valid: emailRegex.test(value),
      error: !emailRegex.test(value)
        ? '有効なメールアドレスを入力してください'
        : null,
    };
  }),
  startWith({
    value: '',
    valid: false,
    error: '有効なメールアドレスを入力してください',
  })
);

// パスワードの検証
const password$ = fromEvent(passwordInput, 'input').pipe(
  map((event) => {
    const value = (event.target as HTMLInputElement).value;
    return {
      value,
      valid: value.length >= 6,
      error: value.length < 6 ? 'パスワードは6文字以上入力してください' : null,
    };
  }),
  startWith({
    value: '',
    valid: false,
    error: 'パスワードは6文字以上入力してください',
  })
);

// 全フィールドの検証状態を組み合わせる
combineLatest([name$, email$, password$])
  .pipe(debounceTime(300))
  .subscribe(([nameState, emailState, passwordState]) => {
    // フォームが有効かどうか
    const isFormValid =
      nameState.valid && emailState.valid && passwordState.valid;
    submitButton.disabled = !isFormValid;

    // エラーメッセージを表示
    if (!isFormValid) {
      const errors = [
        nameState.error,
        emailState.error,
        passwordState.error,
      ].filter((error) => error !== null);

      validationMessage.textContent = errors.join('\n');
    } else {
      validationMessage.textContent = '';
    }
  });

// 送信ボタンのクリックイベント
fromEvent(submitButton, 'click').subscribe(() => {
  const formData = {
    name: nameInput.value,
    email: emailInput.value,
    password: passwordInput.value,
  };

  // フォームデータを表示（実際はAPIに送信）
  const successMessage = document.createElement('div');
  successMessage.textContent = '登録が完了しました！';
  successMessage.style.color = 'green';
  successMessage.style.fontWeight = 'bold';
  successMessage.style.marginTop = '10px';
  formContainer.appendChild(successMessage);

  console.log('送信データ:', formData);
});

同時リクエストとローディング状態の管理

forkJoinを使用して複数のAPIリクエストを並行して処理し、結果をまとめる例です。

import {
  forkJoin,
  of,
  throwError,
  Observable,
  ObservableInputTuple,
} from 'rxjs';
import { catchError, delay, finalize } from 'rxjs';

// インターフェース定義
interface User {
  id: number;
  name: string;
  email: string;
}

interface Post {
  id: number;
  title: string;
  content: string;
}

interface WeatherSuccess {
  city: string;
  temp: number;
  condition: string;
}

interface WeatherError {
  error: string;
}

type Weather = WeatherSuccess | WeatherError;

// 結果の型定義
interface ApiResponse {
  user: User;
  posts: Post[];
  weather: Weather;
}

// UI要素の作成
const apiContainer = document.createElement('div');
apiContainer.innerHTML = '<h3>複数APIリクエストの例:</h3>';
document.body.appendChild(apiContainer);

const loadButton = document.createElement('button');
loadButton.textContent = 'データ読み込み';
loadButton.style.padding = '8px 16px';
apiContainer.appendChild(loadButton);

const loadingIndicator = document.createElement('div');
loadingIndicator.style.margin = '10px 0';
loadingIndicator.style.display = 'none';
apiContainer.appendChild(loadingIndicator);

const resultContainer = document.createElement('div');
apiContainer.appendChild(resultContainer);

// APIリクエストをシミュレート
function fetchUser(id: number): Observable<User> {
  // 成功するリクエスト
  return of({
    id,
    name: `ユーザー${id}`,
    email: `user${id}@example.com`,
  }).pipe(
    delay(2000) // 2秒の遅延
  );
}

function fetchPosts(userId: number): Observable<Post[]> {
  // 成功するリクエスト
  return of([
    { id: 1, title: `${userId}の投稿1`, content: '内容...' },
    { id: 2, title: `${userId}の投稿2`, content: '内容...' },
  ]).pipe(
    delay(1500) // 1.5秒の遅延
  );
}

function fetchWeather(city: string): Observable<WeatherSuccess> {
  // 時々失敗するリクエスト
  const shouldFail = Math.random() > 0.7;

  if (shouldFail) {
    return throwError(() => new Error('天気データの取得に失敗しました')).pipe(
      delay(1000)
    );
  }

  return of({
    city,
    temp: Math.round(15 + Math.random() * 10),
    condition: ['晴れ', '曇り', '雨'][Math.floor(Math.random() * 3)],
  }).pipe(
    delay(1000) // 1秒の遅延
  );
}

// ボタンクリック時に複数リクエストを実行
loadButton.addEventListener('click', () => {
  // UIをリセット
  resultContainer.innerHTML = '';
  loadingIndicator.style.display = 'block';
  loadingIndicator.textContent = 'データ読み込み中...';
  loadButton.disabled = true;

  // 複数のAPIリクエストを同時に実行
  forkJoin({
    user: fetchUser(1),
    posts: fetchPosts(1),
    weather: fetchWeather('東京').pipe(
      // エラー処理
      catchError((error: Error) => {
        console.error('天気APIエラー:', error);
        return of<WeatherError>({ error: error.message });
      })
    ),
  } as ObservableInputTuple<ApiResponse>)
    .pipe(
      // 完了時の処理
      finalize(() => {
        loadingIndicator.style.display = 'none';
        loadButton.disabled = false;
      })
    )
    .subscribe((results: ApiResponse) => {
      // ユーザー情報の表示
      const userInfo = document.createElement('div');
      userInfo.innerHTML = `
      <h4>ユーザー情報</h4>
      <p>名前: ${results.user.name}</p>
      <p>メール: ${results.user.email}</p>
    `;
      userInfo.style.margin = '10px 0';
      userInfo.style.padding = '10px';
      userInfo.style.backgroundColor = '#f0f0f0';
      userInfo.style.borderRadius = '5px';
      resultContainer.appendChild(userInfo);

      // 投稿の表示
      const postsInfo = document.createElement('div');
      postsInfo.innerHTML = `
      <h4>投稿一覧 (${results.posts.length}件)</h4>
      <ul>
        ${results.posts
          .map((post: { title: string }) => `<li>${post.title}</li>`)
          .join('')}
      </ul>
    `;
      postsInfo.style.margin = '10px 0';
      postsInfo.style.padding = '10px';
      postsInfo.style.backgroundColor = '#f0f0f0';
      postsInfo.style.borderRadius = '5px';
      resultContainer.appendChild(postsInfo);

      // 天気情報の表示
      const weatherInfo = document.createElement('div');

      if ('error' in results.weather) {
        weatherInfo.innerHTML = `
        <h4>天気情報</h4>
        <p style="color: red;">エラー: ${results.weather.error}</p>
      `;
      } else {
        weatherInfo.innerHTML = `
        <h4>天気情報</h4>
        <p>都市: ${results.weather.city}</p>
        <p>気温: ${results.weather.temp}°C</p>
        <p>状態: ${results.weather.condition}</p>
      `;
      }

      weatherInfo.style.margin = '10px 0';
      weatherInfo.style.padding = '10px';
      weatherInfo.style.backgroundColor = '#f0f0f0';
      weatherInfo.style.borderRadius = '5px';
      resultContainer.appendChild(weatherInfo);
    });
});

キャンセル可能な検索機能

withLatestFromとraceを組み合わせて、タイムアウトやキャンセル可能な検索機能を実装する例です。

import { fromEvent, timer, race, of, EMPTY } from 'rxjs';
import {
  map,
  debounceTime,
  switchMap,
  tap,
  delay,
  catchError,
  takeUntil,
} from 'rxjs';

// 検索UI作成
const searchContainer = document.createElement('div');
searchContainer.innerHTML = '<h3>キャンセル可能な検索:</h3>';
document.body.appendChild(searchContainer);

// 検索入力欄
const searchInput = document.createElement('input');
searchInput.type = 'text';
searchInput.placeholder = '検索語を入力...';
searchInput.style.padding = '8px';
searchInput.style.width = '250px';
searchContainer.appendChild(searchInput);

// キャンセルボタン
const cancelButton = document.createElement('button');
cancelButton.textContent = 'キャンセル';
cancelButton.style.marginLeft = '10px';
cancelButton.style.padding = '8px 16px';
searchContainer.appendChild(cancelButton);

// 検索結果エリア
const resultsContainer = document.createElement('div');
resultsContainer.style.marginTop = '10px';
resultsContainer.style.minHeight = '200px';
resultsContainer.style.padding = '10px';
resultsContainer.style.border = '1px solid #ddd';
resultsContainer.style.borderRadius = '5px';
searchContainer.appendChild(resultsContainer);

// 検索リクエストをシミュレート
function searchApi(term: string) {
  console.log(`「${term}」の検索を開始...`);

  // 検索結果をシミュレート
  return of([
    `「${term}」の検索結果1`,
    `「${term}」の検索結果2`,
    `「${term}」の検索結果3`,
  ]).pipe(
    // 2〜5秒の遅延をランダムで設定
    delay(2000 + Math.random() * 3000),
    // エラー対応
    catchError((err) => {
      console.error('検索エラー:', err);
      return EMPTY;
    })
  );
}

// キャンセルイベント
const cancel$ = fromEvent(cancelButton, 'click');

// 検索イベント
const search$ = fromEvent(searchInput, 'input')
  .pipe(
    // 入力値を取得
    map((event) => (event.target as HTMLInputElement).value.trim()),
    // 300ms待機
    debounceTime(300),
    // 空の検索は無視
    tap((term) => {
      if (term === '') {
        resultsContainer.innerHTML = '<p>検索語を入力してください</p>';
      }
    }),
    // 空の検索は処理しない
    switchMap((term) => {
      if (term === '') {
        return EMPTY;
      }

      // 検索中表示
      resultsContainer.innerHTML = '<p>検索中...</p>';

      // タイムアウト処理（5秒）
      const timeout$ = timer(5000).pipe(
        tap(() => console.log('検索がタイムアウトしました')),
        map(() => ({ type: 'timeout', results: null }))
      );

      // APIリクエスト
      const request$ = searchApi(term).pipe(
        map((results) => ({ type: 'success', results })),
        // キャンセルボタンが押されたら中止
        takeUntil(
          cancel$.pipe(
            tap(() => {
              console.log('検索がキャンセルされました');
              resultsContainer.innerHTML = '<p>検索はキャンセルされました</p>';
            })
          )
        )
      );

      // タイムアウトかリクエスト完了のどちらか早い方
      return race(request$, timeout$);
    })
  )
  .subscribe((response) => {
    if (response.type === 'success') {
      // 検索成功
      resultsContainer.innerHTML = '<h4>検索結果:</h4>';

      if (response.results?.length === 0) {
        resultsContainer.innerHTML += '<p>結果が見つかりませんでした</p>';
      } else {
        const list = document.createElement('ul');
        response.results?.forEach((result) => {
          const item = document.createElement('li');
          item.textContent = result;
          list.appendChild(item);
        });
        resultsContainer.appendChild(list);
      }
    } else if (response.type === 'timeout') {
      // タイムアウト
      resultsContainer.innerHTML =
        '<p style="color: red;">検索がタイムアウトしました。もう一度お試しください。</p>';
    }
  });

結合オペレーターの比較と選択ガイド

複数の結合オペレーターの違いを比較し、ユースケースに応じた選択をサポートします。

オペレーター	タイミング	出力	ユースケース
`merge`	同時実行	発生順に出力	複数ソースイベントの同時監視
`concat`	順次実行	順番通りに出力	順序が重要な非同期タスク
`combineLatest`	すべてのソースから少なくとも1つの値が必要	すべての最新値の組み合わせ	フォーム入力の検証
`zip`	すべてのソースから対応するインデックスの値が必要	インデックスごとの値の組み合わせ	関連データの同期
`withLatestFrom`	メインソースの値発行時	メインの値と他ソースの最新値	補助データの組み合わせ
`forkJoin`	すべてのソースが完了時	各ソースの最後の値	複数APIリクエスト
`race`	最初に値を発行したソースのみ	勝者のストリームの値のみ	タイムアウト、キャンセル処理

オペレーター選択の判断フロー

すべてのソースから同時に値を受け取りたい？
- Yes → merge
- No → 次へ
ソースの順序を保持したい？
- Yes → concat
- No → 次へ
各ソースの最新値の組み合わせが必要？
- Yes → いつ組み合わせる？
  - 任意のソースの新しい値ごと → combineLatest
  - 特定のメインストリーム値ごと → withLatestFrom
- No → 次へ
インデックス順で対応する値が必要？
- Yes → zip
- No → 次へ
すべてのソースが完了したあとの結果が必要？
- Yes → forkJoin
- No → 次へ
複数の代替ソースから最速のものだけ必要？
- Yes → race
- No → 目的を再検討

スイッチング戦略

複数のデータソースを動的に切り替える例です。

import { fromEvent, merge, interval, of } from 'rxjs';
import { map, switchMap, take, tap } from 'rxjs';

// UI要素の作成
const switchingContainer = document.createElement('div');
switchingContainer.innerHTML = '<h3>データソース切り替え:</h3>';
document.body.appendChild(switchingContainer);

// ボタン作成
const source1Button = document.createElement('button');
source1Button.textContent = 'ソース 1';
source1Button.style.margin = '5px';
source1Button.style.padding = '5px 10px';
switchingContainer.appendChild(source1Button);

const source2Button = document.createElement('button');
source2Button.textContent = 'ソース 2';
source2Button.style.margin = '5px';
source2Button.style.padding = '5px 10px';
switchingContainer.appendChild(source2Button);

const source3Button = document.createElement('button');
source3Button.textContent = 'ソース 3';
source3Button.style.margin = '5px';
source3Button.style.padding = '5px 10px';
switchingContainer.appendChild(source3Button);

// 結果表示エリア
const resultsArea = document.createElement('div');
resultsArea.style.marginTop = '10px';
resultsArea.style.minHeight = '150px';
resultsArea.style.padding = '10px';
resultsArea.style.border = '1px solid #ddd';
resultsArea.style.backgroundColor = '#f9f9f9';
switchingContainer.appendChild(resultsArea);

// 3つのデータソース
function createSource1() {
  return interval(1000).pipe(
    take(5),
    map((val) => `ソース1: ${val}`),
    tap(() => {
      source1Button.style.backgroundColor = '#c8e6c9';
      source2Button.style.backgroundColor = '';
      source3Button.style.backgroundColor = '';
    })
  );
}

function createSource2() {
  return interval(500).pipe(
    take(8),
    map((val) => `ソース2: ${val}`),
    tap(() => {
      source1Button.style.backgroundColor = '';
      source2Button.style.backgroundColor = '#bbdefb';
      source3Button.style.backgroundColor = '';
    })
  );
}

function createSource3() {
  return of('ソース3: A', 'ソース3: B', 'ソース3: C').pipe(
    tap(() => {
      source1Button.style.backgroundColor = '';
      source2Button.style.backgroundColor = '';
      source3Button.style.backgroundColor = '#ffccbc';
    })
  );
}

// ボタンクリックイベント
const source1Click$ = fromEvent(source1Button, 'click').pipe(map(() => 1));

const source2Click$ = fromEvent(source2Button, 'click').pipe(map(() => 2));

const source3Click$ = fromEvent(source3Button, 'click').pipe(map(() => 3));

// ボタンクリックをマージ
merge(source1Click$, source2Click$, source3Click$)
  .pipe(
    // 選択されたソースに切り替え
    switchMap((sourceId) => {
      // 結果エリアをクリア
      resultsArea.innerHTML = '';

      // 選択されたソースを返す
      switch (sourceId) {
        case 1:
          return createSource1();
        case 2:
          return createSource2();
        case 3:
          return createSource3();
        default:
          return of('ソースが選択されていません');
      }
    })
  )
  .subscribe((value) => {
    // 結果を表示
    const item = document.createElement('div');
    item.textContent = value;
    item.style.padding = '5px';
    item.style.margin = '2px 0';
    item.style.backgroundColor = 'white';
    item.style.borderRadius = '3px';
    resultsArea.appendChild(item);
  });

// 初期メッセージ
const initialMessage = document.createElement('div');
initialMessage.textContent =
  'ボタンをクリックしてデータソースを選択してください';
initialMessage.style.color = '#666';
resultsArea.appendChild(initialMessage);

条件付きマージ

mergeとfilterを組み合わせて、条件に基づいたデータソースの選択をする例です。

import { merge, interval, fromEvent } from 'rxjs';
import {
  map,
  filter,
  takeUntil,
  withLatestFrom,
  startWith,
} from 'rxjs';

// UI要素の作成
const conditionalContainer = document.createElement('div');
conditionalContainer.innerHTML = '<h3>条件付きマージ:</h3>';
document.body.appendChild(conditionalContainer);

// フィルター設定
const filterDiv = document.createElement('div');
filterDiv.style.marginBottom = '10px';
conditionalContainer.appendChild(filterDiv);

// チェックボックス作成
const slowCheck = document.createElement('input');
slowCheck.type = 'checkbox';
slowCheck.id = 'slowCheck';
slowCheck.checked = true;
filterDiv.appendChild(slowCheck);

const slowLabel = document.createElement('label');
slowLabel.htmlFor = 'slowCheck';
slowLabel.textContent = '遅いソース';
slowLabel.style.marginRight = '15px';
filterDiv.appendChild(slowLabel);

const fastCheck = document.createElement('input');
fastCheck.type = 'checkbox';
fastCheck.id = 'fastCheck';
fastCheck.checked = true;
filterDiv.appendChild(fastCheck);

const fastLabel = document.createElement('label');
fastLabel.htmlFor = 'fastCheck';
fastLabel.textContent = '速いソース';
fastLabel.style.marginRight = '15px';
filterDiv.appendChild(fastLabel);

const clickCheck = document.createElement('input');
clickCheck.type = 'checkbox';
clickCheck.id = 'clickCheck';
clickCheck.checked = true;
filterDiv.appendChild(clickCheck);

const clickLabel = document.createElement('label');
clickLabel.htmlFor = 'clickCheck';
clickLabel.textContent = 'クリックイベント';
filterDiv.appendChild(clickLabel);

// 停止ボタン
const stopButton = document.createElement('button');
stopButton.textContent = '停止';
stopButton.style.marginLeft = '15px';
filterDiv.appendChild(stopButton);

// 結果表示エリア
const conditionalResults = document.createElement('div');
conditionalResults.style.height = '200px';
conditionalResults.style.overflowY = 'auto';
conditionalResults.style.padding = '10px';
conditionalResults.style.border = '1px solid #ddd';
conditionalResults.style.backgroundColor = '#f9f9f9';
conditionalContainer.appendChild(conditionalResults);

// 3つのデータソース
// 1. 遅いソース (1秒ごと)
const slow$ = interval(1000).pipe(map((val) => ({ type: 'slow', value: val })));

// 2. 速いソース (300ミリ秒ごと)
const fast$ = interval(300).pipe(map((val) => ({ type: 'fast', value: val })));

// 3. クリックイベント
const click$ = fromEvent(document.body, 'click').pipe(
  map((event) => ({
    type: 'click',
    value: {
      x: (event as MouseEvent).clientX,
      y: (event as MouseEvent).clientY,
    },
  }))
);

// チェックボックスの状態を監視
const slowEnabled$ = fromEvent(slowCheck, 'change').pipe(
  map((event) => (event.target as HTMLInputElement).checked),
  startWith(true)
);

const fastEnabled$ = fromEvent(fastCheck, 'change').pipe(
  map((event) => (event.target as HTMLInputElement).checked),
  startWith(true)
);

const clickEnabled$ = fromEvent(clickCheck, 'change').pipe(
  map((event) => (event.target as HTMLInputElement).checked),
  startWith(true)
);

// 停止イベント
const stop$ = fromEvent(stopButton, 'click');

// 条件付きマージ
merge(
  // 遅いソースと有効状態を組み合わせ
  slow$.pipe(
    withLatestFrom(slowEnabled$),
    filter(([_, enabled]) => enabled),
    map(([event]) => event)
  ),

  // 速いソースと有効状態を組み合わせ
  fast$.pipe(
    withLatestFrom(fastEnabled$),
    filter(([_, enabled]) => enabled),
    map(([event]) => event)
  ),

  // クリックソースと有効状態を組み合わせ
  click$.pipe(
    withLatestFrom(clickEnabled$),
    filter(([_, enabled]) => enabled),
    map(([event]) => event)
  )
)
  .pipe(takeUntil(stop$))
  .subscribe((event) => {
    // 結果を表示
    const item = document.createElement('div');

    switch (event.type) {
      case 'slow':
        item.textContent = `遅いソース: ${event.value}`;
        item.style.color = '#1b5e20';
        break;
      case 'fast':
        item.textContent = `速いソース: ${event.value}`;
        item.style.color = '#0d47a1';
        break;
      case 'click':
        const clickValue = event.value as { x: number; y: number };
        item.textContent = `クリック: X=${clickValue.x}, Y=${clickValue.y}`;
        item.style.color = '#bf360c';
        break;
    }

    item.style.padding = '3px';
    item.style.margin = '2px 0';
    conditionalResults.prepend(item); // 新しいものを上に表示
  });

結合オペレーターの選び方まとめ

目的	オペレーター	特徴
複数の最新値を常に同期したい	`combineLatest`	各 Observable の最新値を常に結合
すべての完了後にまとめて取得	`forkJoin`	最後の値だけを出力（1回だけ）
順番に同期的に処理したい	`zip`	各 Observable から 1 つずつ結合して出力
トリガーのときに他の最新値を参照	`withLatestFrom`	主ストリーム発行時に副ストリームの最新値を添付

まとめ

結合オペレーターは、複数のデータソースを組み合わせて一つのストリームにまとめるための強力なツールです。適切なオペレーターを選択することで、複雑な非同期データフローを簡潔かつ宣言的に表現できます。

結合オペレーターを使いこなすためのポイント

ユースケースに合わせた選択: それぞれのオペレーターは特定のユースケースに最適化されています。目的に応じて適切なオペレーターを選びましょう。
発行タイミングの理解: 結合オペレーターの挙動は、値がいつ発行されるかに大きく依存します。各オペレーターの発行タイミングを理解することが重要です。
エラー処理の考慮: 結合されたストリームの一部でエラーが発生した場合の挙動（全体が失敗するか部分的に処理を続けるか）を検討しましょう。
完了条件の把握: 結合されたストリームがいつ完了するかを理解し、必要に応じてtakeUntilなどを使って明示的に完了させることも重要です。
型安全性の活用: TypeScriptを使用することで、結合オペレーターを型安全に扱うことができます。特に複雑な結合では型の恩恵が大きくなります。

結合オペレーターは、UIイベント処理、複数APIリクエスト、フォーム検証など、多くの実践的なシナリオで活用できます。これらのオペレーターをマスターすることで、RxJSのリアクティブプログラミングの真の力を引き出すことができるでしょう。

次は、エラーハンドリングに進んで、より堅牢なRxJSコードの書き方を学びましょう！

基本作成系

ループ生成系

HTTP通信系

結合系

選択・分割系

条件分岐系

制御系

変換オペレーター

フィルタリングオペレーター

結合オペレーター（Pipeable）

ユーティリティオペレーター

条件オペレーター

マルチキャスティング

実践的なユースケース

フォーム入力の検証とAPIリクエスト

同時リクエストとローディング状態の管理

キャンセル可能な検索機能

結合オペレーターの比較と選択ガイド

オペレーター選択の判断フロー

スイッチング戦略

条件付きマージ

結合オペレーターの選び方まとめ

まとめ

結合オペレーターを使いこなすためのポイント

実践的なユースケース ​

フォーム入力の検証とAPIリクエスト ​

同時リクエストとローディング状態の管理 ​

キャンセル可能な検索機能 ​

結合オペレーターの比較と選択ガイド ​

オペレーター選択の判断フロー ​

スイッチング戦略 ​

条件付きマージ ​

結合オペレーターの選び方まとめ ​

まとめ ​

結合オペレーターを使いこなすためのポイント ​

実践的なユースケース

フォーム入力の検証とAPIリクエスト

同時リクエストとローディング状態の管理

キャンセル可能な検索機能

結合オペレーターの比較と選択ガイド

オペレーター選択の判断フロー

スイッチング戦略

条件付きマージ

結合オペレーターの選び方まとめ

まとめ

結合オペレーターを使いこなすためのポイント