将流映射到惰性承诺流

我有一个数字流，我必须使用承诺将它们变成一个帖子流。我想懒惰地这样做。所以如果我这样做.take(1)从帖子流中，它只会将一个数字转换为一篇帖子。

这是从某个号码获取帖子的承诺：

var getPost = function(author) {
  console.log('get post' + author);
  return new RSVP.Promise(function(resolve, reject) {
    setTimeout(function() {
      var result = "Post by " + author;
      resolve(result);
    }, 1000);
  });
};

我只对第一篇文章感兴趣，因此take(1)，并且它应该调用getPost once.

如果我使用map，流工作惰性，调用getPost一次。如果我使用flatmap，它调用getPost对于所有的数字。

var lazyStream = Bacon.fromArray([1, 2, 3, 4]).map(function(value) {
  return Bacon.fromPromise(getPost(value));
});

var nonLazyStream = Bacon.fromArray([1, 2, 3, 4]).flatMap(function(value) {
  return Bacon.fromPromise(getPost(value));
});

lazyStream.take(2).log();
//nonLazyStream.take(2).log();

However map返回一个承诺，同时flatMap返回帖子本身。如何拥有一个返回 Promise 值的惰性流？

flatMap https://github.com/baconjs/bacon.js/#observable-flatmap立即获取由 Promise 创建的所有流，并立即使用所有流生成一个新流。您已经观察到这并不懒惰，并且会立即调用所有承诺返回函数。

你希望这种情况一次发生一个，所以你应该使用flatMapConcat https://github.com/baconjs/bacon.js/#observable-flatmapconcat。它不会一次获取所有流，而是一次调用它们，一一调用承诺 - 这是您通常所期望的.flatMap在其他一些 FRP 库中执行此操作。请注意，这概括了使用flatMapWithConcurrencyLimit https://github.com/baconjs/bacon.js/#observable-flatmapwithconcurrencylimit如果你需要它来做n一次。

这是一个使用的示例flatMapConcat https://github.com/baconjs/bacon.js/#observable-flatmapconcat对于类似的情况：

function delayPromise(val){ // delayed promise simulating an async request
    return new Promise(function(resolve){
      setTimeout(function(){ console.log("Resolve timeout"); resolve(val); }, 500);  
    });
}

var stream = Bacon.fromArray([1, 2, 3, 4]).flatMapConcat(function(value) {
  return Bacon.fromPromise(delayPromise(value));
});

stream.take(1).log();

小提琴链接 http://jsfiddle.net/2bjoqzvq/