Function readStreamBody

src/controllers/cli.chat.js:181–197

* 读取流响应体为文本 * @param {*} stream - 响应流 * @returns {Promise } 文本结果

(stream)

 * @param {*} stream - 响应流
 * @returns {Promise<string>} 文本结果
 */
function readStreamBody(stream) {
    return new Promise((resolve, reject) => {
        if (!stream || typeof stream.on !== 'function') {
            resolve('')
            return
        }

        const chunks = []
        stream.on('data', (chunk) => {
            chunks.push(Buffer.isBuffer(chunk) ? chunk : Buffer.from(String(chunk)))
        })
        stream.on('end', () => {
            resolve(Buffer.concat(chunks).toString('utf8'))
        })
        stream.on('error', reject)
    })
}

/**