我试图理解可观察对象是如何执行的，但似乎无法让这段简单的代码工作。public class RxJavaExample { Observable<String>hello = Observable.fromCallable(() ->
浏览 108提问于2019-07-02得票数 0
回答已采纳
this.http.post(this.loginURL, data, { headers: headers }) .subscribeconsole.log(error.text());}
为了做到这一点(就我所理解的可观察性而
浏览 1提问于2016-08-21得票数 7
回答已采纳
但我不能调用Subject.onNext()，因为我从其他Observables获取其他项 subject.subscribeobserver)
// by the first observable
浏览 13提问于2018-03-05得票数 1
我想知道如何才能在不更改数据的情况下，对可观察对象的线程中发出的数据执行某些操作。()); for(Task task: tasks) System.out.println(task);如何使用运算符在订阅线程中执行此操作？我找到了类似的操作符，比如map，但是在保存到磁盘之后，我必须返回任务列表：
Observable<Lis
浏览 0提问于2015-07-11得票数 0
class RendezVousResolver {
return Observable.createclass MockUserCardService {
return Observable.of('<data}, conso
浏览 0提问于2017-07-17得票数 0
1回答
通常我会使用要创建一个可观察对象，只需执行一次。()) .subscribeOn(AndroidSchedulers.mainThread())observable只执行<
浏览 0提问于2016-09-07得票数 6
3回答
依赖嵌套观测量
、、
我有两个方法，在其中我正在执行一些异步操作，但我不希望方法2执行，直到或者除非方法1的响应是肯定的，以表明我们可以继续进行下去。所以，这就是我试过的：private method1(): Observable<any> { executingSomething}concat(this.method1(), this.method2()).subscribe(
浏览 0提问于2020-12-23得票数 0
回答已采纳
我有两个源观察值，无论它们是否完成，都希望在其中任何一个发出值时执行一些操作： const observable1$ = interval(1000);const onEither$ = merge([ observable2$,
observable1$.pipe(tap(() => console.log('<e
浏览 20提问于2020-04-10得票数 1
回答已采纳
每个操作都具有异步性质(preProcess调用API、downloading等待文件下载等等)。UI必须显示正在执行的操作(例如。“准备.”、“下载.”、“拆包.”)。我把整个过程看作是发出整体操作当前状态的Observable。每个操作也是可观察的，它在执行开始时发出他的状态，并在执行后完成。subscriber.onNext(DownloadStatus.PRE_PROCESS);
浏览 2提问于2015-02-09得票数 4
回答已采纳
2回答
) .observeOn(AndroidSchedulers.mainTread())更新1更新2
请忽略细节，Rx代码大部分时间起作用。我只是为了说
浏览 1提问于2017-09-14得票数 0
4回答
RxJS立即返回数据，为什么？
、、、、
(stringToTranslate: string) { this.translateService.get(stringToTranslate).subscribe不应该将回调函数添加到执行堆栈并在稍后运行吗？
浏览 7提问于2017-03-21得票数 6
回答已采纳
1回答
let connect$ = defer(() => connectAsync());connect$.subscribe(); // --|>是否有任何rxjs操作符或主题可以用来实现行为？
浏览 2提问于2022-01-26得票数 0
回答已采纳
我计划发布一篇文章来执行一次打印。我不需要从这个调用中返回任何东西。我一直在使用.subscribe(x => this.data = x)执行我的调用，知道我不需要任何返回的东西，是否可以在不使用.subscribe(...)的情况下执行这个可观察的调用
浏览 14提问于2019-04-08得票数 0
回答已采纳
我有一个api，比如：Observable<RespData> doSomeThing(@Body ReqData reqData);
并且它可能会同时被多次调用
浏览 2提问于2016-08-02得票数 1
constructor() {}// component/class 2
someObservable$.subscribe(value
浏览 1提问于2021-03-04得票数 0
1回答
我在代码中替换了对使用者的操作调用，但在订阅它时，一直要求我将其转换为观察者public void fetchSubscriptionPlans(String url, String apiKey.subscribe(subscriptionPlans); Observable.just((List.subscribe(subscriptionPlans); }
浏览 6提问于2020-07-09得票数 0
回答已采纳
我使用的是PublishSubject和map操作符：public void testMapWithMultipleObservers() {
observable.subscribe</em
浏览 4提问于2015-07-17得票数 1
回答已采纳
1回答
因此，基本上，我需要执行两个操作：
observer.onCompleted() }
我知道这是不对的，因为当两个操作都完成时，
浏览 1提问于2017-08-31得票数 0
一个简单的例子： let observable = Rx.Observable.create().publish(); return observable;
myFunc().subscribe(x => console.log(x))
浏览 0提问于2017-04-11得票数 1
1回答
我有一个可观察的，它正在执行一个网络请求并发出数据。为此，我有多个订阅者，而且由于我不想为每个新的子脚本重新执行网络请求，所以我使用replay().autoConnect()操作符多播可观察到的内容。这很好，对于我的第二个订阅者来说，它可以立即获得数据而不需要重新执行网络请求，因为replay操作符缓存了旧的结果。但问题是，我不希望修改这个缓存的数据。有可能使用任何操作员吗？或者对这个问题有任何Rx解决方案吗？我想我的问题很清楚。
浏览 0提问于2018-01-21得票数 1
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
