gpt4 book ai didi

rx-java - 实时计数 rx 中发出的元素

转载 作者:行者123 更新时间:2023-12-02 05:42:08 27 4
gpt4 key购买 nike

有没有办法计算 RxAndroid 中流中已处理的元素数量?

我有类似的事情:

Observable.fromArray(new String[]{"these", "are", "my", "values", "."})
.map(s -> doSomeCoolStuff(s))
// ...
.subscribe(amountOfProcessedItems -> Log.d("test", "" + amountOfProcessedItems));

我正在寻找一些东西,以便我的输出看起来像 1 2 3 4 5,基本上是在每个项目计算已发出的项目数量之后。

最佳答案

只计算元素:

AtomicInteger counter = new AtomicInteger();
Observable.fromArray(new String[]{"these", "are", "my", "values", "."})
.map(s -> doSomeCoolStuff(s))
// ...
.subscribe(dummy -> Log.d("test", "" + counter.incrementAndGet()));

编辑:如果您只想将元素转换为递增整数,请按以下步骤操作:

sourceOservable
.zipWith(Observable.range(0, Integer.MAX_VALUE), (any, counter) -> counter)
.whatever(...)

关于rx-java - 实时计数 rx 中发出的元素,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42873681/

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