我正在尝试设计一个Angular服务，它使用其他服务来提供这些服务的元数据。数据对象是具有连接类的不同类别的人。(即客户、顾问和销售关系。)this.clientService.clientArray().map( ..... ).subscribe(i => this.unmatchedClients.next(i)
浏览 13提问于2017-12-09得票数 0
我有一个Observable<List<Event>>，我想让多个订阅者共享这个可观察对象。每个订阅者将过滤每个事件并对其进行处理。Observable<List<Event>>是这样创建的： @Override List<Event::just)
.filter(funding
浏览 67提问于2020-11-25得票数 0
在groupBy操作之外，可以创建由以下代码描述的管道，例如，根据某些条件从可观察的记录中选择一个记录，或者选择满足某些替代条件的第一个记录：Observable<Long> filter1 = observable.filter</
浏览 0提问于2014-08-19得票数 2
1回答
我有一个通过系统进程执行任务的可观察对象(这是热的)，我希望有一个间隔也在运行，直到可观察进程命中onComplete。我看到区间运算符：
我如何结合这两个来获得我想要的行为(特别是，当另一个点击onComplete时取消间隔)？
浏览 1提问于2017-03-21得票数 0
下面是我的代码，在for循环中，我调用了delete方法，但我想在再次调用之前等待funcion完成。我有一个公司和一个项目类，在project类中有一个公司数组，这包含了连接到项目的公司列表。} }
this.companies = this.companies.filter
浏览 4提问于2017-11-27得票数 1
回答已采纳
1回答
我有一个函数，当它在其他地方被订阅时，我需要返回一个可观察对象，但因为我的函数异步地发出请求，然后试图将该数据作为可观察对象返回，所以它正在中断。(select).subscribe(users => { return asObservabl
浏览 18提问于2021-11-10得票数 0
回答已采纳
我在我的服务中有一些功能，它允许我们在组件中获取和订阅数据publicresponseData => this.privateLessons = responseData}
如何在初始化时从函数中存储数据(在应用程序加载时下载一次，而不是订阅
浏览 0提问于2018-01-15得票数 0
我正在尝试键入一个可以观察到的对象，并使用自定义的Symbol.observable填充(类似于下面所示的；代码)，但我想不出一种方法。我尝试过使用typeof $$observable作为密钥，并尝试将Symbol.observable作为unique symbol，但这两种方法都不起作用。或者，我想知道是否有一种方法可以在更细粒度的级别上转换它，而不是对整个对象进行强制转换(如果结果证明没有强制转换是不可能的)。
浏览 1提问于2020-05-14得票数 3
回答已采纳
2回答
我需要知道如何在错误抛出后保持订阅。我创造了一个可以观察到的：因此，我尝试过使用Observable.empty，但据我所知，它发出的是一个完整的，所以订阅者将被删除：
this.saved$ = saveClick$.pipe(this.pushUser(), catchError(() =
浏览 0提问于2019-06-18得票数 3
回答已采纳
1回答
如何在Angular中返回在injectable上调用的订阅？所以我一开始花了一个小时才弄明白的是： returnURLNotes(): Observable<any> {
浏览 12提问于2019-04-21得票数 1
回答已采纳
设置：父组件是否可以公开可观察到的组件，子组件是否可以订阅它？我不清楚，使用filter=“可观察”，在什么时候订阅。......<child-component [filter]="filterObservable"
浏览 3提问于2021-04-28得票数 0
我的应用程序中有两种“类型”的 Observable：
Observable，它只返回数据，从不返回Error，因此我可以安全地将.subscribe()传递给Observable而不传递error可能返回数据或返回Observable的Error，所以在订阅可观察到的数据时，我应该同时提供一个next和一个error回调。Observable.throw()返回一个ErrorObservabl
浏览 0提问于2017-11-22得票数 1
此外，服务通常在多个地方使用，因此它们的Observable应该在订阅者之间共享。ReminderService提供了一个无限的Observable<List<Reminder>>，它在数据集中的每次更改之后发出所有存储的提醒信息的列表。LocationAwareReminderService，提供了由前两个服务的Observable.combineLate
浏览 6提问于2016-04-13得票数 6
回答已采纳
1回答
合并多个共享过滤器
、、、
我已经和RxSwift一起工作了一段时间了，我刚刚转向了合并，我正试图把我的头脑集中在这个特定的.filter行为上。filter2: request unlimited令我惊讶的是，Result is: 2从未被调用，因为流结束了。我可以删除.share()操作符，这将像我所期望的那样接收两个值filter</em
浏览 0提问于2021-11-12得票数 1
回答已采纳
好了，我是一个完全的Rx初学者，不幸的是，我对js和js中的流也是非常陌生的。我正在使用这个连接到twitters流api，并接收带有tweet的json对象。require('rxjs/Rx');
fs = require('fs'); track:
浏览 0提问于2017-03-06得票数 2
我使用RxAndroid，我想过滤Observable<List<Item>>的结果。以下是代码：Observable.create((Observable.OnSubscribe<List<Item>>) subscriber()只获取有效的项。这样做是完美的：
observable.filter
浏览 5提问于2016-09-19得票数 5
回答已采纳
我想知道像.map()这样的RxJS操作符是如何‘监听’传入的可观察流的。.map()和其他RxJS操作符是否在幕后订阅流，以便访问可观察值？如果我理解正确的话，每个操作符都订阅了输入可观察值，这使它可以访问值流，然后将转换后的值的可观察值返回给下一个操作符？感谢您的任何澄清。
浏览 0提问于2020-10-04得票数 2
我发誓RxJS会要了我的命。我很确定这是RxJS、Typescript或Angular实现的一个实际错误。这适用于 (该页面上的javascript控制台作为RxJS沙箱工作)： id: 0,name: 'John Doe' id: 1, }]))
.map(data =>
浏览 0提问于2017-10-19得票数 1
1回答
我有一个包含键/值对的map。从这个map中，我将它们存储到一个作为结果Observable<String>返回的数据库中。当我试图在不阻塞的情况下访问此字符串并将其放在列表中时，我的问题就出现了。public Observable<List<String>> uploadKeys(Map<String, String> entries) {
浏览 2提问于2017-12-20得票数 2
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
