使用 RxJava (ReactiveX) 运行 一个 Observable 需要多长时间？

Question

我在 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)

我如何测量可观察到 运行 花费的时间？

提前致谢

弗朗西斯

Answer 1

您需要在 doOnSubscribe() 块中开始计时，然后在 onTerminated() 中完成。

一个例子可能是这样的：

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

或者，您可以按照 Netflix 使用 RxNetty 和 return 将开始时间作为流经链的对象的一部分进行操作，并在最后使用它。