java - 如何使用 ConnectableObservable 预取然后将处理后的数据用于不同的订阅者

Question

在我的应用程序中，我需要在应用程序启动后立即加载大量数据。另外，当数据加载到某些 fragment/Activity 中时，我需要接收一个事件。

我正在使用 RxJava ConnectableObservable 来实现此目的。我使用了 replay() 因为我需要为多个订阅者提供相同的数据。

伪代码:

 Observable.create(emitter -> {
            try {
                Data next = getDataFromDb();
                emitter.onNext(next);
                emitter.onCompleted();
            } catch (SQLiteException e) {
                emitter.onError(e);
            }
        }, Emitter.BackpressureMode.BUFFER)
        .toList()
        .compose(applySchedulers())
        .replay()

现在，如果我想预取数据，我应该在应用程序类中订阅，然后在 Activity/Fragment 中使用 connect() 吗？

Answer 1

试试这个:

observable = Observable.create(emitter -> {
        try {
            Data next = getDataFromDb();
            emitter.onNext(next);
        } catch (SQLiteException e) {
            emitter.onError(e);
        }
    }, Emitter.BackpressureMode.BUFFER)
    .toList()
    .compose(applySchedulers())
    .replay(1)
    .autoConnect()
//start your prefetch
observable.subscribe()//you should better add some log to see the process

//In your Activity
observable.subscribe(/**Your Subscribe**/)// here you will get the replayed value

请注意:

1. 您应该保留 Observable 的相同实例，否则您无法获取重放值

2. 您应该使用 autoConnect() 的其他重载例如autoConnect(int numberOfSubscribers, @NonNull Consumer<? super Disposable> connection)并获取上游源的一次性(RxJava 1.x 订阅)。