使用 X 射线写入结束错误后

Question

我在我的 MEAN.js 项目中使用 X 射线库，但我无法修复此错误消息：

Error: write after end at writeAfterEnd (_stream_writable.js:166:12) at Writable.write (_stream_writable.js:211:5) at Writable.end (_stream_writable.js:446:10) at _stream_object (C:\src\je\foodleWeb\node_modules\x-ray\lib\stream.js:46:16) at next (C:\src\je\foodleWeb\node_modules\x-ray\index.js:137:11) at C:\src\je\foodleWeb\node_modules\x-ray\index.js:242:7 at C:\src\je\foodleWeb\node_modules\x-ray\lib\walk.js:56:12 at callback (C:\src\je\foodleWeb\node_modules\batch\index.js:147:12) at C:\src\je\foodleWeb\node_modules\x-ray\lib\walk.js:49:9 at C:\src\je\foodleWeb\node_modules\x-ray\index.js:232:24 at next (C:\src\je\foodleWeb\node_modules\x-ray\index.js:138:11) at C:\src\je\foodleWeb\node_modules\x-ray\index.js:242:7 at C:\src\je\foodleWeb\node_modules\x-ray\lib\walk.js:56:12 at callback (C:\src\je\foodleWeb\node_modules\batch\index.js:147:12) at C:\src\je\foodleWeb\node_modules\x-ray\lib\walk.js:39:11 at C:\src\je\foodleWeb\node_modules\x-ray\lib\walk.js:56:12 at callback (C:\src\je\foodleWeb\node_modules\batch\index.js:147:12) at C:\src\je\foodleWeb\node_modules\x-ray\lib\walk.js:49:9 at C:\src\je\foodleWeb\node_modules\x-ray\index.js:212:18 at next (C:\src\je\foodleWeb\node_modules\x-ray\index.js:138:11) at C:\src\je\foodleWeb\node_modules\x-ray\index.js:242:7 at C:\src\je\foodleWeb\node_modules\x-ray\lib\walk.js:56:12

这是我的代码，我在其中使用内置函数 "pipe" 将响应传回 $http

export function show(req, res) {
  var stream = x(url,
    [{
      text: '.name'
    }])(function (err, data) {
      if (err) {
        console.log("[Xray] Error:", err);
      }
      else {
        return data;
      }
    }).stream();

  stream.pipe(res);
}

我试过使用以下方法来捕获异常，但效果不佳，因为它是基于 promises 的。我想要类似的东西以防止应用程序崩溃。

也许我可以将我的代码包装到一个函数中并传入一个回调或类似的东西...

function respondWithResult(res, statusCode) {
  statusCode = statusCode || 200;
  return function (entity) {
    if (entity) {
      res.status(statusCode).json(entity);
    }
  };
}

function handleError(res, statusCode) {
  statusCode = statusCode || 500;
  return function (err) {
    res.status(statusCode).send(err);
  };
}

export function index(req, res) {
  return Squeme.find().exec()
    .then(respondWithResult(res))
    .catch(handleError(res));
}

Answer 1

我从评论中复制我的解决方案，因为似乎没有人提供解决方法

我可能会通过不使用管道函数并以这种方式构建响应找到解决方案：return res.status(200).json(data);

使用 X 射线写入结束错误后

Write after end error using x-ray

node.js

meanjs

x-ray