我有一系列事件:
var eventStream = _([{
id: 1, foo: 'bar'
}, {
id: 2, foo: 'baz'
}]);
对于流中的每个事件,我需要加载一个模型实例(我的 DAL 返回 Promise),然后在模型的每个实例上调用一个方法,将原始事件数据中的一些数据作为参数传递。
加载模型实例并不太困难:
eventStream.map(function(data) {
return getModelPromise(data.id);
}).map(_).merge(); // result is a stream of model instances
但是一旦我有了模型,我就无法弄清楚如何调用模型上的方法并将其传递data.foo
给它。基本上,对于我需要做的每个实例:
modelInstance.doStuff(data.foo);
我玩过分叉流,在分叉上拉模型,然后以不同的组合使用zip
和invoke
,但我没有任何运气。使用 async,我可以通过适当的闭包用户来非常简单地处理这个问题。如何使用 highland.js 使用流来完成此操作?