gpt4 book ai didi

c# - 根据可观察序列中的事件顺序执行操作

转载 作者:行者123 更新时间:2023-11-30 21:07:36 28 4
gpt4 key购买 nike

我有三个(或更多)可观察的 bool 序列:

IObservable<bool> a0 = ...;
IObservable<bool> a1 = ...;
IObservable<bool> a2 = ...;

这些序列主要生成 false 值,但偶尔会有一个 true(序列也可以为空)。我对值本身不感兴趣,而是对 true 值的顺序感兴趣。因此,如果 a0true,则 a2 为 true,最后 a1,我想执行一些操作:

(a0, a2, a1) => ...do something...

但是如果 true 值以另一个顺序出现,我想做一些别的事情:

(a2, a1, a0) => ...do something else...
(a0, a1, a2) => ...do something entirely else...

所以我只对每个序列的第一个 true 值感兴趣,并且根据它们出现的顺序,我想执行一些操作。

我可以记录每次第一次出现 true 的时间戳,然后在 CombineLatest 调用中排序,但我觉得有更好的方法。这种方法的一个问题是我现在依赖于记录时间戳的粒度。

最佳答案

首先,您只需要真正的值,忽略其余部分。其次,您可以将每个 observable 编码为更具语义的含义(也许是字符串?)。第三,然后您可以合并这些流,等待 3 个值到达,并根据它们采取行动。

设置:

var a0 = new Subject<bool>();
var a1 = new Subject<bool>();
var a2 = new Subject<bool>();

编码:

var a0t = a0.Where(x => x).Select(x => "a0").Take(1); // thanks Matthew Finlay
var a1t = a1.Where(x => x).Select(x => "a1").Take(1);
var a2t = a2.Where(x => x).Select(x => "a2").Take(1);

合并并获取三个值:

var merged = a0t.Merge(a1t).Merge(a2t);
var message = merged.Buffer(3).Subscribe(x => ProcessMessage(String.Join("", x)));

处理部分:

public void ProcessMessage(string message)
{
switch(message) {
case "a0a1a2": Console.WriteLine("1"); break;
case "a1a2a0": Console.WriteLine("2"); break;
case "a2a1a0": Console.WriteLine("3"); break;
}
}

并测试:

a1.OnNext(true);
a2.OnNext(true);
a0.OnNext(true);

关于c# - 根据可观察序列中的事件顺序执行操作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/10280657/

28 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com