node.js - 将HighlandJS流与http请求一起使用

我想获取一个网址数组，并将其映射到每个网址的pagerank数组。

我想通过流进行尝试，但是不确定我是否了解我在做什么。

我已经尝试了几件事，这是我登陆的地方（不工作）：

app.js

var getPageRank = require('pagerank');
var _ = require('highland');

var urls = [
    'google.com',
    'yahoo.com',
    'bing.com'
];

// Example usage of getPageRank
getPageRank(urls[0], function(err, ranking) {
    console.log(ranking);
});

var getPR = _.wrapCallback(getPageRank);

_(urls).map(getPR).toArray(function (myAnswer) {
    console.log(myAnswer);
});

package.json

{
  "name": "page-rank",
  "version": "0.0.0",
  "description": "",
  "main": "app.js",
  "scripts": {
  },
  "author": "",
  "license": "ISC",
  "dependencies": {
    "highland": "^2.5.1",
    "pagerank": "^2.0.0"
  }
}

输出似乎是一个流数组，从toArray（）和google的页面排名9中出来似乎很奇怪。我不知道如何包装getPageRank以便它等待在回调中返回值。

最佳答案

由于具有流，因此可以使用Stream.merge()或Stream.flatten()将每个流中的值合并到新流中：

_(urls).map(getPR).merge().toArray(function (myAnswer) {
    console.log(myAnswer);
});