java - 在 RxKotlin / RxJava 中使用 BehaviorSubject 惯用地创建热可观察对象

Question

目前我正在使用 RxKotlin 在 Kotlin 中构建一个项目。我在 Rx 方面的背景主要是基于 RxJS。

我经常用于hot observables在 Typescript 中创建的模式看起来类似于以下内容：

  private dataStore: IFoo;
  private dataStoreSubject: BehaviorSubject<IFoo> = new BehaviorSubject(this.dataStore);
  public dataStoreObservable: Observable<IFoo> = Observable.from(this.dataStoreSubject);

  public getNetworkData(): Observable<IFoo[]> {
      return this.http.get()
         .map((response: IResponse) => {
             this.dataStore = <IFoo[]>response;
             this.dataStoreSubject.next(this.dataStore);
             return this.dataStore;
          });
   }

这将允许我公开Observable，而不公开 theSubject和随后的subject.next();方法。

我的问题是：在 RxKotlin 或 RxJava 中建立类似逻辑的最惯用的方法是什么？

Answer 1

您需要使用撰写和转换。您可以在您的主题和可观察对象之间添加“链接”到转换中。