将 Bacon.Bus 的价值与承诺的价值相结合

Question

我正在使用BaconJS 在 FRP 领域迈出一小步。我有以下代码：

# This will eventually get resolved with some value
dfd = Promise.defer()
promised = Bacon.fromPromise dfd.promise

# Values are occasionally being pushed in here
bus = new Bacon.Bus

# 1. attempt
bus.combine promised, (fromBus, fromPromise) ->
   # This is never invoked

# 2. attempt
Bacon.combineAsArray( bus, promised ).onValues (fromBus, fromPromise) ->
   # This is invoked only once for the latest value from the bus

# 3. attempt
promised.sampledBy(bus).onValue (fromPromise, fromBus) ->
   # No invoke here at all

# These are called asynchronously during application lifespan
bus.push obj1
dfd.resolve value
bus.push obj2
bus.push obj3

我想通过 Bus 使用来自 promise 对象的值更新每个交付的对象，包括那些在解决 promise 之前被推送到那里的值。我可以这样做：

bus.onValue (fromBus) ->
    promise.then (fromPromise) ->
        ...

是的，这行得通，但我就是不喜欢它，我想看看 FRP 是否可以更优雅地解决它。请问你有什么纯FRP方式的提示吗？

更新

我正在考虑其他一些方法。以下是实际发生的一些背景...

# Simple function that creates some object instance (if it haven't been created yet ) and returns it
getObject = (name) ->
   unless obj = list[name]
     obj = new Obj()
     bus.push obj

对于添加到缓存中的每个对象，我需要将一些属性设置为来自 Promise 的值。基本上我可以这样做：

obj = new Obj()
dfd.promise.then (resolvedValue) ->
    obj.someProperty = resolvedValue

这是没有 FRP 的完全可行的解决方案，但是您可能知道，每个 .then 调用都被强制为异步的。它以较低的性能付出了代价。我想克服这一点。如果我理解正确，使用 FRP 只会调用一次.then，然后提供静态值。问题仍然是如何做到这一点......

已解决

查看fiddle。简而言之，它可以是这样的：

bus.flatMap(
    Bacon.combineAsArray.bind Bacon, promised
).onValue ([fromPromise, fromBus]) ->
    fromBus.specialProperty = fromPromise

Answer 1

看起来你正在寻找flatMap（再次）：

busValuesWithPromise = bus.flatMap (busValue) ->
    Bacon.combineAsArray(promised, busValue)
busValuesWithPromise.onValues (fromPromise, fromBus) ->
    # every bus update, together with the promise value