我在React Native中使用带有rxjs 5.5.12的代码，它可以工作。在rxjs 5.5.12中： rxInit() {import { combineLatest } from 'rxjs';
import { flatMap } from 'rxjs/
浏览 3提问于2019-10-30得票数 0
回答已采纳
1回答
加载大量项目时的尾递归
、、、
对于每个请求，我使用一个可观察的，然后结合几个与combineLatest。在combineLatest之后，我执行一个flatMap和concat，一个对同一个函数的新调用。func loadRecursively(items) -> Observable<XY> { .flatMap {
浏览 1提问于2018-03-24得票数 2
我尝试将.combineLatest与设置的时间间隔结合使用，以便每5秒发出一个新值。然后，我将this.dailyStocks作为输入传递给子组件，但每次传递到输入的数据都是相同的，并且当我查看开发工具中的网络选项卡时，我没有看到进行了额外的调用。.flatMap(() => { this.http.getData(args),
浏览 0提问于2017-12-06得票数 1
回答已采纳
我很难在不同的步骤中使用flatMap和reduce。我有一个可观察到的wordCount，它绑定到UIStepper值，并生成一个具有给定数量单词的新密码。 let reducedPassword = rawPassword现在，我想从UI中更改单词分隔符。当来自rawPassword的文本被更新时，我只想在我
浏览 5提问于2016-08-24得票数 1
回答已采纳
>和Observable<Person?>，并返回Observablereturn Observable.combineLatest(self.id, personStream)updatedPerson) in }) return person} self.id,
浏览 11提问于2018-01-27得票数 1
回答已采纳
下面的代码会导致使用Observable.combineLatest is not a function 5.0的RxJS：我正在使用webpack和babel编译所有内容，代码能够解决scan、range、interval、map等问题。即使是使用flatMap的impo
浏览 1提问于2016-03-14得票数 35
回答已采纳
1回答
我正在尝试使用两个单独的函数调用来验证用户的电子邮件和密码。这两个函数都返回验证发布器，我使用combineLatest将返回值收集到一个元组中(每次AnyPublisher调用都返回它正在验证的字符串)。然后，我使用flatMap发出一个网络请求，让用户使用combineLatest返回的值进行注册，但是从未调用过flatMap操作符。validator.validate(text: email, with: [.
浏览 6提问于2019-12-24得票数 1
回答已采纳
我正在用Angular8和rxjs6构建一个应用程序。我正致力于将逻辑从一个大型组件中分离出来，成为一个服务。
我使用combineLatest函数来获得多个可观测值的结果。然后在combineLatest subscribe(=>{})的主体中，使用结果数据更新多个BehaviorSubjects。combineLatest代码在组件的主体中工作得很好，因为我可以将其余的逻辑放在订阅体中。但是，我希望将<em
浏览 0提问于2019-07-12得票数 0
回答已采纳
> { .flatMap { }.toList() .flatMap {Observable.combineLatest(it) {
var owner
浏览 1提问于2017-07-27得票数 0
1回答
然后，我必须遍历每个用户，并从远程url中获取他们的化身，并将其保存到磁盘中。我可以在subscribe内执行第二个任务，但这不是最佳实践。我正在尝试用map、flatMap等实现它。首先是使用rx on URLSession，它在另一个线程的后台执行任务，并且无法在此操作完成时确认主subscribe。其次是循环和rx，这是不有效的，因为它应该生成多个可观测值，然后处理它。
浏览 0提问于2019-04-15得票数 2
回答已采纳
当我更改任何一个页面触发器时，只有当一个页面触发器发生变化时，我才需要获得页面触发器，observable_page.中的哪个 .withLatestF
浏览 1提问于2018-10-28得票数 3
我正在使用RxAndroidBle并跟踪。我有一个可以观察到的主动联系。我想要观察的特征是一个名为AP_SCAN_DATA的UUID。它应该发出0xFE以响应接收到的书面0xFF。RxBleConnection connection) { .flatMapsubscribe();
浏览 2提问于2016-12-14得票数 1
回答已采纳
1回答
我正在结合他们的结果，并产生新的可观测性(signUp)。发生了什么：当用户点击signUpButton (signUpTrigger)时，我从putProfileImage和createUser可观测到的数据中获取数据，但从signUp中得不到任何可观察的数据alt=media&token=85c68612-bea4-41a5-a680-88a61c2e8989)final class SignUpViewModel: ViewModelTypecreateUse
浏览 1提问于2020-08-31得票数 1
回答已采纳
3回答
订阅中的更新值
、、
它有一个间隔订阅来生成api调用，我不能使用全局变量，因为它是一个服务，它可以在不删除注入器的情况下进行发票。const interval = observableInterval(refreshInterval).pipe(startWith(0))
flatMap正如我所说，我不能使用this.init，因为我的代码。
浏览 1提问于2019-01-15得票数 0
回答已采纳
因此，我有一些RxSwift代码，其中我想要执行一系列异步操作，所有这些操作都是使用可观察到的。flatMap是实现这一目标的方法，它工作得很好，但是它似乎无法将变量传递到我所能理解的链中。就像这样 .flatMap{ connection in connection.sendData("foo") } .subscribeNext{ /* all done *&
浏览 3提问于2016-04-28得票数 10
回答已采纳
=pretty').then(res => res.json()));var fetchedNews$ = Rx.Observable.combineLatest(news, pager) => news.slice((pager.current - 1) * pager.items_per_page, pager.items_per_page))
.flatMapinstance instead of <em>array of fetched news
浏览 1提问于2016-09-22得票数 0
回答已采纳
现在，我可以传递关键字或页码，但不能同时在Rx中传递。request_call = Observable.of(stringObservable, intObservable).merge() .flatMap{ input in
Observable.combineLatest(Observable.just($0), api.loadData(page: $0, keyword:我需要两者合并，我使用了ENUM &
浏览 0提问于2018-10-26得票数 0
回答已采纳
3回答
我使用retrofit进行两个API调用，A和B，它们都返回一个可观察到的对象列表。两个API调用都是独立的，所以我想同时进行，但是要达到我的最终结果，我需要先得到A的结果，做一些工作，然后结合B的结果来填充我的列表适配器。object_b") Observable<List<Object_B>> getObjectBList( @Path("object_id") long object_id)；
这就是我试图使用我可以获得api调用A的结果并完成我的工作，但
浏览 3提问于2014-11-10得票数 9
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
