WebSerial API 完整介绍

const port = await navigator.serial.requestPort()

const ports =  await navigator.serial.getPorts()
// 返回一个端口列表

async function readSerial(port) {
  while (port.readable) {
    const reader = port.readable.getReader();
    try {
      for await (const { value, done } of reader) {
        if (done) {
          // |reader| 已取消。
          break;
        }
        // 使用 |value| 进行一些操作...
      }
    } catch (error) {
      // 处理 |error|...
    } finally {
      reader.releaseLock();
    }
  }
}

// LineBreakTransformer.js
class LineBreakTransformer {
  constructor() {
    // 用于保存流数据的容器，直到新行到来。
    this.container = "";
  }

  transform(chunk, controller) {
    // 处理传入的块
    this.container += chunk;
    const lines = this.container.split("\r\n");
    this.container = lines.pop();
    lines.forEach((line) => controller.enqueue(line));
  }

  flush(controller) {
    // 刷新流。
    controller.enqueue(this.container);
  }
}

export default LineBreakTransformer;

const decoder = new TextDecoderStream();
port.readable.pipeTo(decoder.writable);
const inputStream = decoder.readable.pipeThrough(
  new TransformStream(new LineBreakTransformer())
);
console.log(inputStream, "INPUT STREAM");
const reader = inputStream.getReader();

async function readSerial(port) {
  while (port.readable) {
    try {
      for await (const { value, done } of reader) {
        if (done) {
          // |reader| 已取消。
          break;
        }
        // 使用 |value| 进行一些操作...
      }
    } catch (error) {
      // 处理 |error|...
    } finally {
      reader.releaseLock();
    }
  }
}