利用可观测数据进行进度监测的设计模式

Question

我有一个java方法，它执行异步项处理并返回一个Observable。

我希望向调用方提供进度监视信息。

想到的第一件事是返回一个第二个，并将它们添加到一个包装类中。

是否有其他方式或最佳实践可以使用可观察到的方式提供进度监视功能？

Answer 1

我想到的第一件事是，timestamp操作符whitch返回一个可观察到的Timed<T>

@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
public final Observable<Timed<T>> timestamp() {
    return timestamp(TimeUnit.MILLISECONDS, Schedulers.computation());
}

您可以执行一些类似的操作，并将对象包装在Progress对象上，如下所示：

public final class Progress<T> {
  final int percent;
  final T value
}

value是您的原始对象，percent是进度的值。