From 33058f2b292b3a581333bdfb21b8f671898c5060 Mon Sep 17 00:00:00 2001 From: Peter Bengtsson Date: Tue, 8 Dec 2020 14:40:17 -0500 Subject: initial commit --- files/ja/web/api/transformstream/index.html | 168 ++++++++++++++++++++++++++++ 1 file changed, 168 insertions(+) create mode 100644 files/ja/web/api/transformstream/index.html (limited to 'files/ja/web/api/transformstream') diff --git a/files/ja/web/api/transformstream/index.html b/files/ja/web/api/transformstream/index.html new file mode 100644 index 0000000000..16fd3fa37c --- /dev/null +++ b/files/ja/web/api/transformstream/index.html @@ -0,0 +1,168 @@ +--- +title: TransformStream +slug: Web/API/TransformStream +tags: + - API + - Interface + - Streams API + - TransformStream + - Web + - インターフェイス +translation_of: Web/API/TransformStream +--- +
{{APIRef("Media Capture and Streams")}}
+ +

TransformStream は Streams API のインターフェイスで一連の変換可能なデータを表します。

+ +

コンストラクター

+ +
+
{{domxref("TransformStream.TransformStream", "TransformStream()")}}
+
指定されたハンドラーから変換ストリームを作成して返却します。
+
+ +

プロパティ

+ +
+
{{domxref("TransformStream.readable")}} {{readonlyInline}}
+
TransformStream の readable 側の端点です。
+
{{domxref("TransformStream.writable")}} {{readonlyInline}}
+
TransformStream の writable 側の端点です。
+
+ +

メソッド

+ +

なし

+ +

例

+ +

何かを uint8array に変換するストリーム

+ +

以下の例では、変換ストリームは受信したすべてのチャンクを {{domxref("Uint8Array")}} の値に渡します。

+ +
const transformContent = {
+  start() {}, // required.
+  async transform(chunk, controller) {
+    chunk = await chunk
+    switch (typeof chunk) {
+      case 'object':
+        // just say the stream is done I guess
+        if (chunk === null) controller.terminate()
+        else if (ArrayBuffer.isView(chunk))
+          controller.enqueue(new Uint8Array(chunk.buffer, chunk.byteOffset, chunk.byteLength))
+        else if (Array.isArray(chunk) && chunk.every(value => typeof value === 'number'))
+          controller.enqueue(new Uint8Array(chunk))
+        else if ('function' === typeof chunk.valueOf && chunk.valueOf() !== chunk)
+          this.transform(chunk.valueOf(), controller) // hack
+        else if ('toJSON' in chunk) this.transform(JSON.stringify(chunk), controller)
+        break
+      case 'symbol':
+        controller.error("Cannot send a symbol as a chunk part")
+        break
+      case 'undefined':
+        controller.error("Cannot send undefined as a chunk part")
+      default:
+        controller.enqueue(this.textencoder.encode(String(chunk)))
+        break
+  },
+  flush() { /* do any destructor work here */ }
+}
+
+class AnyToU8Stream extends TransformStream {
+  constructor() {
+    super({...transformContent, textencoder: new TextEncoder()})
+  }
+}
+
+ +

TextEncoderStream および TextDecoderStream の代替

+ +

なお、これはネイティブのコンストラクターを使っているため非推奨です。これは対応していないプラットフォームで代替とすることを意図しています。

+ +
const tes = {
+  start(){this.encoder = new TextEncoder()},
+  transform(chunk, controller) {
+    controller.enqueue(this.encoder.encode(chunk))
+  }
+}
+let _jstes_wm = new WeakMap(); /* info holder */
+class JSTextEncoderStream extends TransformStream {
+  constructor() {
+    let t = {...tes}
+
+    super(t)
+    _jstes_wm.set(this, t)
+  }
+  get encoding() {return _jstes_wm.get(this).encoder.encoding}
+}
+
+ +

同様に、 TextDecoderStream は次のように書くことができます。

+ +
const tes = {
+  start(){
+    this.decoder = new TextDecoder(this.encoding, this.options)
+  },
+  transform(chunk, controller) {
+    controller.enqueue(this.decoder.decode(chunk))
+  }
+}
+let _jstds_wm = new WeakMap(); /* info holder */
+class JSTextDecoderStream extends TransformStream {
+  constructor(encoding = 'utf-8', {...options} = {}) {
+    let t = {...tds, encoding, options}
+
+    super(t)
+    _jstes_wm.set(this, t)
+  }
+  get encoding() {return _jstds_wm.get(this).decoder.encoding}
+  get fatal() {return _jstds_wm.get(this).decoder.fatal}
+  get ignoreBOM() {return _jstds_wm.get(this).decoder.ignoreBOM}
+}
+
+ +

複数の ReadableStreams を互いに結合

+ +

これは、複数のストリームを結合できる便利なものです。例ではプログレッシブ読み込みやプログレッシブストリーミングを持つ PWA の構築が含まれます。

+ +
let responses = [ /* conjoined response tree */ ]
+let {readable, writable} = new TransformStream
+
+responses.reduce(
+  (a, res, i, arr) => a.then(() => res.pipeTo(writable, {preventClose: (i+1) !== arr.length})),
+  Promise.resolve()
+)
+
+ +

これは他への影響に対して耐性がないことに注意してください。

+ +

仕様書

+ + + + + + + + + + + + + + + + +
仕様書状態備考
{{SpecName('Media Capture', '#dom-mediastream', 'MediaStream')}}{{Spec2('Media Capture')}}初回定義
+ +

ブラウザーの互換性

+ + + +

{{Compat("api.TransformStream")}}

+ +

関連情報

+ + -- cgit v1.2.3-54-g00ecf