o$.pipe()
.subscribe(result => this.secondHandler()); 我倾向于认为我需要使用基本上，我需要的是当一个事件发生时，我需要用不同的返回处理程序并行调用2个API。
浏览 12提问于2019-10-11得票数 0
2回答
我阅读了文档，以了解如何根据从API收到的响应继续调用api。我正在调用一个只能一次发回2k记录的2k。API将为我发送一个值，以便我能够继续接收记录，直到它们返回一个完成的值为止。如果我接收到一个value，那么我需要发出相同的请求，但是发送带有值的reqMode参数。
如果我接收到done，那么我将停止并返回自第一次调用
浏览 7提问于2016-09-30得票数 4
回答已采纳
我在使用RxJava (v1.2.1)正确实现以下场景时遇到了问题：return Observable.just(localDataCall())
.concatW
浏览 0提问于2016-10-21得票数 2
我需要向服务器执行几个请求。下一个请求依赖于前一个请求的结果。> obsCreateToken = api.createToken();我已经使用flatMap创建了一个单独的observable，它返回PaymentResponse对象，或者在某些要求不满足时发出</e
浏览 26提问于2017-03-08得票数 8
回答已采纳
2回答
保持简单和简短，如何在另一个订阅者的onNext()方法中订阅一个可观察对象，以便只有在当前可观察对象完成执行时才能进行嵌套订阅。这两个订阅都将在单独的线程上进行，并且要求第一个线程必须在第二个线程启动之前完成其执行。
浏览 8提问于2016-08-31得票数 2
回答已采纳
3回答
有条件地发射可观察对象
、、、、
我们有一个带有Redux (ngrx 4)的Angular 4应用程序。我们将信息"isLoggedIn“保存在ngrx/store中，当我们向http发出调用时，我们必须首先检查他是否经过身份验证。我们正在努力解决的是进行http调用的服务的实现：
constructor(private http: HttpClientpublic getProducts(): Observable<ProductL
浏览 4提问于2017-08-17得票数 0
回答已采纳
我有一个使用NGRX的角形9应用程序，它大部分使用可观测/主题和assync管道。updateNavbarMenuItems(items: NavbarActionModel[]) { }
return this.navbarMenuItems.asObservable();}
当从任何其他组件调用NavbarServi
浏览 2提问于2020-03-06得票数 1
回答已采纳
我有第二个Observable<Boolean>，它接受一个字符串并将它放到一个队列中，并发出该操作是否成功。我希望“链接”这两个可观察到的对象，以便当Observable<String>发出路径时，Observable<Boolean>将其放在队列中并返回它是否成功。最后，我想得到一个执行这两种操作的可观察的单一操作。
我还没有找到任何让我做我想做的事情的API
浏览 1提问于2015-08-18得票数 2
回答已采纳
每个可观察到的请求都是递归调用，当没有更多的数据时，它将调用空。callforJoin(request, request2, request3).subscribe();
当所有可观察到的数据都完成时，发出最后一个发出的<e
浏览 0提问于2018-09-26得票数 2
this.api.ObsA(), this.api.ObsCombined()ObsB是一个BehaviourSubject，它的起始值是Null.when ObsA emits，如果ObsCombined发出"null“作为下一个值，则必须重置ObsB值(我将调用obs
浏览 2提问于2020-12-15得票数 0
我想创建一个可以在Angular 6中传递一些参数的observale。下面是在Angular site 中创建observable的示例代码，但它没有解释如何传递任何参数。. // Get the next and error callbacks.const {next, error} = observer;
// Simple geolocation <e
浏览 0提问于2018-09-20得票数 6
回答已采纳
基础是我有几个动作要执行，有些需要按顺序进行，有些则不是。下面是我需要调用的4个方法。createOrder(order:Order):Observable<void>{ //DoSomething )
updateCurrentStock(order:Ord
浏览 0提问于2020-12-17得票数 1
我有一个类型的温度，例如： source: "Sensor A",}现在，我希望对每个温度对象执行一个副作用 (api调用)，并将这些调用的结果附加到对象(当所有调用都被解析<e
浏览 1提问于2017-11-24得票数 2
回答已采纳
1回答
我是usimg角2，我在其中一个场景中使用了forkjoin，其中我必须在parallel.Following中执行多个rest调用是我的函数。private getBatchObservableData(data: Array<Widget>): Observable<any> {
浏览 2提问于2017-10-26得票数 2
回答已采纳
我希望构建的应用程序具有以下功能：
当开关翻转时，应该运行相同的功能，但不完全是这样。当前正在运行的查询(如果正在运行)将过时，因为url-前缀将更改。它应该再等待1秒，然后启动一个新的网络调
浏览 0提问于2015-04-13得票数 1
回答已采纳
1回答
我有一个基于时间的算法，在某些情况下，两种排放可能发生在同一时刻，来自不同的可观测值。当一条消息与计时器同时出现时，其行为是随机的。有时会发出一个新的Action，而其他时候则不会，优先使用takeUntil(messages)。
我需要对这种行为有一个完全的控制。moment中，执行takeUntil，不发出任何值。但是在服务器上，在现实世界中，当JVM同时做多件事情时<
浏览 2提问于2019-02-11得票数 1
1回答
我想要实现的是:我想通过每5分钟轮询一次，但只有当有一个观察者订阅的时候，我想从网络上投票一些资源。我使用BehaviorSubject和interval作为池。我就是这样做的：private Subscription> subscription;
if (observable == null
浏览 4提问于2016-02-16得票数 2
回答已采纳
但是，如果在请求服务器时出现错误，则从rx底部调用取消订阅。validPassword(): Observable<CharSequence> //last password of length 我有一个注册方法，由Retrofit fun authorize(email:String, pass:String): Obs
浏览 2提问于2016-06-27得票数 0
回答已采纳
1回答
我正在尝试获得异步生成的两个可观测数据的元素，并将它们作为参数传递给一个函数(一旦接收到这两个变量)。 self.api = api }在我的ViewController
浏览 3提问于2020-02-20得票数 1
我正在使用RXJS方法，我希望处理发出的值(当对应的可观测值完成时)，然后在代码中的其他地方跟踪相同Observable的状态(完全、错误、等待.)。第一步是使用forkJoin，它工作得很好，但我必须等待所有的Observable完成工作，如果我subscribe到一个函数getStuff(x)，Observable就被“消耗”了，forkJoinObservable1 = getStuff(a); // <em
浏览 0提问于2018-10-15得票数 3
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号