在RxKotlin / RxJava中使用BehaviorSubject惯用地创建热可观察值
在RxKotlin / RxJava中使用BehaviorSubject惯用地创建热可观察值
提问于 2018-02-02 01:08:04
目前，我正在使用RxKotlin在Kotlin中构建一个项目。我使用Rx的背景主要是基于RxJS。
我经常用来在Typescript中创建hot observables的模式是这样的：
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，而不公开Subject和随后的subject.next();方法。
我的问题是:在RxKotlin或RxJava中建立类似逻辑最常用的方法是什么？
回答 1
Stack Overflow用户
发布于 2019-02-19 03:59:26
您需要使用compose和transform。您可以在转换中添加主题和可观察对象之间的“链接”。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/48568178
复制相关文章
相似问题
腾讯云开发者
