How to write blob into the device

[gws0920]

我想把用户选择的本地文件写入到手机中，如果直接将 file.stream()传入到sync.write参数中，手机中只会得到一个空文件，我应该怎么做呢

const fileHandles = await showOpenFilePicker({ multiple: true })
const adb = getAdb()
const sync = await adb?.sync()
if (!sync) return

for (let i = 0; i < fileHandles.length; i++) {
  const fileHandle = fileHandles[i]
  const file = await fileHandle.getFile()
  const stream = file.stream()

  await sync.write({ filename: `${pathStr.value}/${fileHandle.name}`, file: stream })
  // 类型“ReadableStream<Uint8Array>”缺少类型“ReadableStream<Consumable<Uint8Array>>”中的以下属性: values, [Symbol.asyncIterator]ts(2739)
}

[gws0920]

我在这里找到了参考

https://github.com/yume-chan/ya-webadb/blob/b066ca01e7c6d17e02c969db94c458f9cd5d0463/apps/demo/src/pages/file-manager.tsx

const fileHandles = await showOpenFilePicker({ multiple: true })
  const adb = getAdb()
  const sync = await adb?.sync()
  if (!sync) return

  for (let i = 0; i < fileHandles.length; i++) {
    const fileHandle = fileHandles[i]
    const file = await fileHandle.getFile()
    const stream = new WrapReadableStream<Uint8Array>(
      file.stream() as unknown as ReadableStream<Uint8Array>
    )
      .pipeThrough(new WrapConsumableStream())
      .pipeThrough(new ProgressStream((v) => {
        console.log('progress: ', +(v / file.size * 100).toFixed(1) + '%')
      }))
    await sync.write({ filename: `${pathStr.value}/${fileHandle.name}`, file: stream })
  }

export class ProgressStream extends InspectStream<Consumable<Uint8Array>> {
  public constructor (onProgress: (value: number) => void) {
    let progress = 0
    super((chunk) => {
      progress += chunk.value.byteLength
      onProgress(progress)
    })
  }
}

[yume-chan]

I added a new doc page explaining the Consumable: https://docs.tangoapp.dev/tango/comsumable/

[gws0920]

Good!!!