gpt4 book ai didi

c# - 我如何计算 Hot observables?

转载 作者:太空宇宙 更新时间:2023-11-03 21:42:14 26 4
gpt4 key购买 nike

我有以下 Observable。

IObservable<MyDto> observable;

现在,为了计算 Observable 中的项目数量,我不能使用以下代码,因为我的 observable 是热的并且长时间运行,并且永远不会调用对“count”的订阅。

var count = observable.Count()

我希望在每次元素到达时都得到计数,这是我正在尝试做的事情

observable.Subscribe(o => Console.WriteLine(" Object received "));
observable.Count().Subscribe(c => Console.WriteLine("Current count is " + c.ToString() + " but this is not final count, more are coming"));

我怎样才能做到这一点?

最佳答案

使用Scan :

observable
.Scan(0, (count, _) => count + 1)
.Subscribe(count => Console.WriteLine("Current count is " + count));

关于c# - 我如何计算 Hot observables?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18762610/

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