Koa2 -如何写入响应流？

Question

使用Koa2和我不知道如何将数据写入响应流，所以在Express中应该是这样的：

res.write('some string');

我知道我可以为ctx.body分配一个流，但是我对node.js流不太熟悉，所以不知道如何创建这个流。

Answer 1

koa文档允许您为您的响应分配流：(来自https://koajs.com/#response)

ctx.response.body=

将响应体设置为以下之一：

• 串写
• 缓冲器写入
• 溪流管道
• 对象\x数组json-字符串化
• 空无内容响应

ctx.body只是通往ctx.response.body的捷径

下面是一些如何使用它的例子(加上标准的koa身体分配)

调用服务器

• 本地主机:8080/流..。将用数据流进行响应。
• 本地主机:8080/文件..。将用文件流进行响应。
• 本地主机:8080/.只是送回标准的身体

'use strict';
const koa = require('koa');
const fs = require('fs');

const app = new koa();

const readable = require('stream').Readable
const s = new readable;

// response
app.use(ctx => {
    if (ctx.request.url === '/stream') {
        // stream data
        s.push('STREAM: Hello, World!');
        s.push(null); // indicates end of the stream
        ctx.body = s;
    } else if (ctx.request.url === '/file') {
        // stream file
        const src = fs.createReadStream('./big.file');
        ctx.response.set("content-type", "text/html");
        ctx.body = src;
    } else {
        // normal KOA response
        ctx.body = 'BODY: Hello, World!' ;
    }
});

app.listen(8080);