2 篇博文 含有标签「ReadStream」

import { Readable } from "stream"

const reader = readAbleStream.getReader()

const readStream = new Readable({
    read() {
        reader.read().then(({ done, value }) => {
            if (done) readStream.push(null)
            else readStream.push(value)
        })
    },
})

async function* nodeStreamToIterator(stream: ReadStream): AsyncGenerator<Buffer, void, never> {
    for await (const chunk of stream) yield chunk
}

function iteratorToStream(iterator: AsyncGenerator<Buffer, void, never>): ReadableStream {
    return new ReadableStream({
        async pull(controller) {
            const { value, done } = await iterator.next()

            if (done) controller.close()
            else controller.enqueue(value)
        },
    })
}

import { Readable } from "stream"

async function main() {
    const response = await fetch("http://example.com")
    const readable = Readable.fromWeb(response.body as any)
}

main()

// response 就是 ReadStream
http.get("http://localhost:3000/hello", response => {
    response.pipe(res)
})