RxJava2中具有多个订阅方的单个异步事件

Question

我有一个类处理一个图像，这可能是一个缓慢的过程。当工作完成时，该类包含图像的一些特性，如主色。

我有许多其他的代码想知道主颜色，当他们要求它时，它可能是或可能没有准备好。

我还没有找到使用RXJava2实现这一点的简单方法。有人能帮帮我吗？

null

ReplaySubject似乎有一些我正在寻找的属性，但我不确定如何正确地实现它。

Answer 1

'1.允许多个订阅者调用/订阅。
'4.在稍后点订阅/调用该方法的订阅者只获得缓存的值。

将replay(1)与autoconnect()结合使用。这将导致一个可观察到的共享对源的单个订阅，并重播源发出的最后一个值。autoconnect()确保在第一个订阅服务器订阅时直接订阅源。

使用Observable.create()并使用ObservableEmitter发出结果。

Observable.create(new ObservableOnSubscribe<String>() {
  @Override
  public void subscribe(final ObservableEmitter<String> e) throws Exception {
    Thread.sleep(5000);
    e.onNext("Test");
    e.onComplete();
  }
}).replay(1).autoConnect()
    .firstOrError();