@Bruce Lee can you try again now? It should be fixed

if (md.val) {
  console.log("MD", md.val)
  await env.CONTENT_BUCKET.put(`${key}-md`, new ReadableStream(md.val))
}

if (md.val) {
  console.log("MD", md.val)
  await env.CONTENT_BUCKET.put(`${key}-md`, new ReadableStream(md.val))
}

Uncaught (in promise) TypeError: Provided readable stream must have a known length (request/response body or readable half of FixedLengthStream)

Uncaught (in promise) TypeError: Provided readable stream must have a known length (request/response body or readable half of FixedLengthStream)

while (true) {
  let foo = await reader.read();
  if (foo.value) {
  console.log(foo.value)
  let md = metadataExtractor.extract(foo.value)
  if (md.val) {
    let encoder = new TextEncoder()
    let strung = encoder.encode(JSON.stringify(md.val))
    console.log("MD", strung)
    console.log(strung.length)
    let {readable, writable} = new FixedLengthStream(strung.length)
    let writer = writable.getWriter()
    await writer.write(strung).then(e => console.log({e}))
    await env.CONTENT_BUCKET.put(`${key}-md`, readable)
    console.log("PUT METADATA IN R2")
  }
}

while (true) {
  let foo = await reader.read();
  if (foo.value) {
  console.log(foo.value)
  let md = metadataExtractor.extract(foo.value)
  if (md.val) {
    let encoder = new TextEncoder()
    let strung = encoder.encode(JSON.stringify(md.val))
    console.log("MD", strung)
    console.log(strung.length)
    let {readable, writable} = new FixedLengthStream(strung.length)
    let writer = writable.getWriter()
    await writer.write(strung).then(e => console.log({e}))
    await env.CONTENT_BUCKET.put(`${key}-md`, readable)
    console.log("PUT METADATA IN R2")
  }
}

A hanging Promise was canceled. This happens when the worker runtime is waiting for a Promise from JavaScript to resolve, but has detected that the Promise cannot possibly ever resolve because all code and events related to the Promise's I/O context have already finished.
A hanging Promise was canceled. This happens when the worker runtime is waiting for a Promise from JavaScript to resolve, but has detected that the Promise cannot possibly ever resolve because all code and events related to the Promise's I/O context have already finished.

A hanging Promise was canceled. This happens when the worker runtime is waiting for a Promise from JavaScript to resolve, but has detected that the Promise cannot possibly ever resolve because all code and events related to the Promise's I/O context have already finished.
A hanging Promise was canceled. This happens when the worker runtime is waiting for a Promise from JavaScript to resolve, but has detected that the Promise cannot possibly ever resolve because all code and events related to the Promise's I/O context have already finished.

writer.write(strung).then(() => {
  env.CONTENT_BUCKET.put(`${key}-md`, readable)
}))

writer.write(strung).then(() => {
  env.CONTENT_BUCKET.put(`${key}-md`, readable)
}))

if (foo.done) {
                        break
                    }
                }
                metadataExtractor.clear()
                await bucketUpload;
                await env.CONTENT_BUCKET.put(`${key}-md`, readable)
        return new Response(`Put ${key} successfully! with count of ${count}`);

if (foo.done) {
                        break
                    }
                }
                metadataExtractor.clear()
                await bucketUpload;
                await env.CONTENT_BUCKET.put(`${key}-md`, readable)
        return new Response(`Put ${key} successfully! with count of ${count}`);