如何使用Graph Client返回的ReadableStream并转为Node常规Readable？

遇到的这种ReadableStream是Microsoft Graph SDK封装的自定义流对象，和标准Web流、Node.js可读流不兼容，可通过以下方式转换：

方法一：手动封装为Node Readable #

基于Node.js的stream.Readable类，手动读取自定义流的数据并推送：

const { Readable } = require('stream');

async function convertToNodeReadable(graphStream) {
  return new Readable({
    async read() {
      try {
        // 调用自定义流的读取方法，若SDK版本不同，可能是next()等，需参考文档
        const chunk = await graphStream.read();
        if (chunk === null) {
          this.push(null); // 标记流结束
          return;
        }
        this.push(chunk);
      } catch (err) {
        this.destroy(err); // 传递读取错误
      }
    }
  });
}

方法二：Buffer中转（适合小体积头像） #

如果头像文件不大，可先将整个流转为Buffer，再生成Node可读流：

const { Readable } = require('stream');

async function graphStreamToNodeStream(graphStream) {
  const chunks = [];
  let chunk;
  // 循环读取所有数据块
  while ((chunk = await graphStream.read()) !== null) {
    chunks.push(chunk);
  }
  const buffer = Buffer.concat(chunks);
  return Readable.from(buffer);
}

额外提示 #

• 优先检查SDK版本：部分新版本的Microsoft Graph Client已修复流兼容性问题，升级SDK可能直接解决；
• 若自定义流支持事件监听，也可通过事件封装：

const { Readable } = require('stream');

function convertViaEvents(graphStream) {
  const nodeStream = new Readable({ read() {} });
  graphStream.on('data', chunk => nodeStream.push(chunk));
  graphStream.on('end', () => nodeStream.push(null));
  graphStream.on('error', err => nodeStream.destroy(err));
  return nodeStream;
}

内容的提问来源于stack exchange，提问作者user3896248