haskell - 响应式(Reactive)香蕉:触发包含行为的最新值的事件

Question

假设我有一个事件触发器，我想在触发时做两件事。首先，我希望它更新某些行为的值。其次，如果满足其他条件，我希望它使用行为的更新值触发另一个事件 send_off 。以代码形式表达，假设我有

trigger :: Event b
trigger = ...

updateFromTrigger :: b -> (a -> a)
updateFromTrigger = ...

conditionFromTrigger :: b -> Bool
conditionFromTrigger = ...

behavior :: Behavior a
behavior = accumB initial_value (updateFromTrigger <$> trigger)

send_off :: Event a
send_off = ?????? (filterE conditionFromTrigger trigger)

那么问题是:我该在 ?????? 里放什么？这样 send_off 会发送行为的最新值，我的意思是该值包含来自 trigger 的更新，该值刚刚应用于它。

不幸的是，如果我理解正确的话，Behavior 的语义是这样的，更新后的值不能立即提供给我，所以我在这里唯一的选择本质上是复制工作并重新计算 Behaviour 的更新值，以便我可以立即在另一个事件中使用它，即填写 ??????类似的东西

send_off =
    flip updateFromTrigger
    <$>
    behavior
    <@>
    filterE conditionFromTrigger trigger

现在，从某种意义上说，我可以通过使用离散而不是行为来立即获得行为中的更新信息，但实际上这相当于给我与我的原始事件同时触发并具有更新值的事件，除非我错过了一些东西，否则响应式(Reactive)香蕉不会给我一种仅当其他两个事件同时触发时才触发事件的方法；也就是说，它提供事件的并集，但不提供交集。

所以我有两个问题。首先，我对这种情况的理解是否正确，特别是我的结论是否正确:我的上述解决方案是解决该问题的唯一方法？其次，纯粹出于好奇，开发者对于如何处理事件的交叉有什么想法或计划吗？

Answer 1

问得好!

不幸的是，我认为这里存在一个没有简单解决方案的根本问题。问题如下:您需要最新的累积值，但触发器可能包含同时发生的事件(仍按顺序排列)。那么，

Which of the simultaneous accumulator updates is going to be the most recent?

要点是更新在它们所属的事件流中排序，但与其他事件流无关。这里使用的 FRP 语义不再知道哪个同时更新的行为对应于哪个同时send_off事件。特别是，这表明您建议的 send_off 实现可能不正确；当trigger包含同时事件时它不起作用，因为行为可能会更新多次，但您只重新计算更新一次。

考虑到这一点，我可以想到解决该问题的几种方法:

1. 使用mapAccum使用新更新的累加器值来注释每个触发事件。

   (trigger', behavior) = mapAccum initial_value $ f <$> trigger
       where
       f x acc = (x, updateFromTrigger acc)
   
   send_off = fmap snd . filterE (conditionFromTrigger . fst) $ trigger'
   

   我认为这个解决方案在模块化方面有点缺乏，但根据上面的讨论，这可能很难避免。

2. 根据离散重新构建所有内容。

   我在这里没有任何具体建议，但您的 send_off 事件可能感觉更像是值的更新，而不是正确的事件。在这种情况下，可能值得根据 Discrete 来转换所有内容，其 Applicative 实例在同时发生事件时执行“正确的操作”。

   本着类似的精神，我经常使用 changes 。 AccumD 而不是 accumE，因为它感觉更自然。

3. reactive-banana 的下一个版本 (> 0.4.3) 可能会包含函数

   collect :: Event a   -> Event [a]
   spread  :: Event [a] -> Event a
   

   具体化，分别。反射(reflect)同时发生的事件。无论如何，我需要它们来优化 Discrete 类型，但它们可能对于像当前问题这样的东西也很有用。

   特别是，它们将允许您这样定义事件的交集:

   intersect :: Event a -> Event b -> Event (a,b)
   intersect e1 e2
           = spread . fmap f . collect
           $ (Left <$> e1) `union` (Right <$> e2)
       where
       f xs = zipWith (\(Left x) (Right y) -> (x,y)) left right
         where (left, right) = span isLeft xs 
   

   但是，根据上面的讨论，此功能可能没有您希望的那么有用。特别是，它不是唯一的，有很多变体。