SerialSession の概要

このページは公開 API の考え方をまとめたものです。各 SerialSession 面の役割、SerialSessionState と state$ の対応、receive$ / lines$ / terminalText$ の使い分け（選び方）。state$ が canonical lifecycle source、errors$ が canonical error event channel です。オプション、エラーコード、型の詳細は API Reference（TypeDoc）を参照してください。

ドキュメント

まず以下を参照してください。

機能

Session 指向のリアクティブ API: 1 つの SerialSession が state$（canonical lifecycle discriminated union）/ errors$（error event channel）/ receive$ / lines$ と connect$ / disconnect$ / dispose$ / send$ を公開
UTF-8 テキストストリーム: receive$ は内部でストリーミング TextDecoder を用いてデコード済み。マルチバイト文字がチャンクにまたがっても正しく結合されます
順序保証された送信キュー: 並行する send$ 呼び出しも内部キューで FIFO 処理され、呼び出し順に書き込まれます
統一エラーチャネル: すべての I/O エラーは SerialError に正規化され errors$ に多重化されます
明示的なライフサイクル: state$ は status を持つ discriminated union（idle / connecting / connected / disconnecting / unsupported / error / disposed）を emit するので、state.status で narrowing できます
TypeScript サポート: 完全な TypeScript 型定義を同梱
フレームワーク非依存: 任意の JavaScript/TypeScript フレームワークまたはバニラ JavaScript で利用可能

対応フレームワーク

このライブラリはフレームワーク非依存で、以下の環境で利用できます。

Angular
React
Vue
Svelte
Vanilla JavaScript / TypeScript

SerialSession の全体像

createSerialSession が返す SerialSession だけを使います。公開 API は意図的に小さく、未フレーミングの UTF-8 デコードチャンク（ターミナルや \r 再描画向け。ワイヤ上の生バイトではない）は receive$、改行区切りのログや解析は lines$ が担当します。ライフサイクル UI には state$ の state.status narrowing を優先してください。対応範囲: 対応範囲。

公開面	役割
`state$`	Canonical 接続ライフサイクル — discriminated union（`status` + 必要に応じ `portInfo` / `error`）。購読時に現在値をリプレイ。分岐は `SerialSessionStatus` との比較を推奨。
`SerialSessionStatus`	状態定数 — エクスポートされる const object（例: `SerialSessionStatus.Connected` → `'connected'`）。`state$.status` と比較する。
`SerialSessionState`	`state$` の payload 型 — discriminated union。
`receive$`	デコード済みテキストチャンク — UTF-8 テキストを read pump が返すとおりに受け取る（行揃えではない。マルチバイト安全。ワイヤ上の生バイトではない）。`\r` 等も保持。ターミナル風の表示や `\r` による上書き表示向け。
`terminalText$`	ターミナル表示向けの累積テキスト — `receive$` 由来の表示用テキスト。`\r` による上書きを折りたたみつつ通常の改行挙動は維持します。既定ではプレーンテキスト UI 向けに ANSI エスケープを除去します（生データは `receive$`）。ターミナル風ビューへ 1 つの文字列をそのままバインドしたい場合に使います。既定では完了行 10,000 行・文字数 1,048,576 文字まで保持します（`SerialSessionOptions.terminalBuffer` で変更可能）。
`lines$`	行単位の受信 — `\n` / `\r\n` / 内部の `\r` など実装に従い 1 行ずつ emit。ログ・1 行ごとの解析向け。`\r` をそのまま残す必要がある未フレーミングのターミナル表示には向かない。
`errors$`	Canonical error event channel — 接続・読み取り・書き込み・クローズのすべての `SerialError`（fatal / non-fatal）。
`connect$()`	ポート選択 → オープン → 内部 read pump 開始。
`disconnect$()`	ポートを閉じ、pump を停止。セッションは `idle` に戻り再利用可能。
`dispose$()`	セッションを永久破棄。接続を閉じ、すべての Observable を complete し、再利用不可にする。
`send$(string \| Uint8Array)`	送信を FIFO で直列化（並行 `send$` も呼び出し順）。

トップレベル（SerialSession のメンバーではない）: isWebSerialSupported() — セッション生成前や connect$ の前に使う、Web Serial 利用可否の同期的な boolean。

SerialSessionStatus（早見表）

state$ の各 variant は status フィールドを持ちます。コードでは const オブジェクト（例: SerialSessionStatus.Connected → 'connected'）での比較を推奨します。

定数	値	意味
`SerialSessionStatus.Idle`	`'idle'`	ポート未接続。Web Serial 利用可能な場合の初期値。
`SerialSessionStatus.Connecting`	`'connecting'`	`connect$` 実行中。
`SerialSessionStatus.Connected`	`'connected'`	ポートが開き、内部 read pump が動作中。`portInfo` 付き。
`SerialSessionStatus.Disconnecting`	`'disconnecting'`	`disconnect$` 実行中。
`SerialSessionStatus.Unsupported`	`'unsupported'`	セッション生成時点で Web Serial が利用できない。
`SerialSessionStatus.Error`	`'error'`	接続まわりの致命エラー。`error` 付き。
`SerialSessionStatus.Disposed`	`'disposed'`	`dispose$` により永久破棄。すべての Observable が complete。

receive$ / lines$ / terminalText$: 用途で選んでください — 改行ログ・パーサ → lines$、未フレーミングのデコードチャンクやカスタムフレーミング → receive$、ターミナル風 UI へのバインド → terminalText$。比較表は receive$ / lines$ / terminalText$ の選び方。対応範囲: 対応範囲。

UI 用の接続 boolean — フラグだけ必要な場合は state$ から derive するか（高度な使用方法）、state.status === SerialSessionStatus.Connected で narrowing してください。削除された convenience API は v4 への移行 – Phase 1 API 削除を参照してください。

最小サンプル

import {
  createSerialSession,
  isConnectedSessionState,
  isWebSerialSupported,
} from '@gurezo/web-serial-rxjs';
import { concatMap, filter } from 'rxjs';

const session = createSerialSession({ baudRate: 115200 });

if (!isWebSerialSupported()) {
  throw new Error('このブラウザでは Web Serial を利用できません');
}

session.lines$.subscribe(console.log);
session.errors$.subscribe(console.error);
session.state$
  .pipe(filter(isConnectedSessionState))
  .subscribe((state) => {
    console.log(state.portInfo);
  });
session
  .connect$()
  .pipe(concatMap(() => session.send$('hello\r\n')))
  .subscribe({ error: console.error });

connect$() が完了する前に send$() すると PORT_NOT_OPEN になります。connect$() はクリックなどのユーザー操作から開始してください。そうでないとブラウザはポート選択ダイアログを開きません。実アプリではこの購読の error を扱ってください（errors$ にも流れます）。手順の全体はクイックスタートを参照してください。

ドキュメント索引

全件索引は日本語 Guide です。Getting Started、How-to、Reference、Project の4区分に分かれています。

ドキュメント	用途
日本語 Guide 索引	全件索引。Getting Started、How-to、Reference、Project。
English Guide 索引	The same four sections, in English.
リポジトリ README	モノレポ全体の目次、サンプル索引、貢献の導線。