我在scala Play Framework 2.5中使用java ReactiveX(RxJava)与couchbase异步通信我想知道我的observable运行需要多长时间？我使用下面的代码定义我的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()块中启动计时器,然后在onTerminated()中完成它.
一个例子可能是这样的：
long start;
observable()
.doOnSubscribe(() -> start = System.nanoTime())
.doOnTerminate(() -> System.out.println(System.nanoTime() - start));
或者,您可以按照Netflix对RxNetty执行的操作,并将开始时间作为流经链的对象的一部分返回,并在最后使用它.
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
