gpt4 book ai didi

java - 使用 RxJava (ReactiveX) 运行 Observable 需要多长时间?

转载 作者:搜寻专家 更新时间:2023-10-31 19:32:20 25 4
gpt4 key购买 nike

我在 scala Play Framework 2.5 中使用 java ReactiveX (RxJava) 与 couchbase 异步通信 我想知道我的 observable 运行需要多长时间?我使用下面的代码定义我的可观察对象。

def get(id: String) : Observable[Profile] = {
this.bucket
.async()
// can I have a start time here possibly using map?
.get(id)
.map[Profile](toProfile)
// can I have an end time here possibly using map?
}

我用下面的方式调用它

Thread.sleep(1000)

val observable = get("myID")

Thread.sleep(1000)

// measure start time here
println("observable: " + observable.toBlocking.first())
// measure end time here

Thread.sleep(1000)

我如何测量可观察对象运行所花费的时间?

提前致谢

弗朗西斯

最佳答案

您需要在 doOnSubscribe() block 中启动计时器,然后在 onTerminated() 中完成它。

一个例子可能是这样的:

long start;
observable()
.doOnSubscribe(() -> start = System.nanoTime())
.doOnTerminate(() -> System.out.println(System.nanoTime() - start));

或者,您可以按照 Netflix 使用 RxNetty 所做的操作,将开始时间作为流经链的对象的一部分返回,并在最后使用它。

关于java - 使用 RxJava (ReactiveX) 运行 Observable 需要多长时间?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36900314/

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