2回答
目前，我正在使用setTimeout获取contactInfoArry。
我想在subscribe事件结束时使用RxJS来获取'contactInfoArry‘，而不是setTimeout。
浏览 13提问于2018-07-19得票数 0
回答已采纳
2回答
从Fi还原流取消订阅-角
、、、、
最近，我将Firebase实现到了我的Recently中，我有一个关于从数据流中取消订阅的问题。当您使用经典的HTTP调用时，来自于此的可观察性是有限的，但是对于防火墙，这些调用是无限的，所以您必须取消订阅。FirebaseError:缺少或不足的权限
而且，即使我在角度上使用async管道，我仍然会得到一个错误。
浏览 3提问于2019-12-14得票数 0
1回答
我正在尝试创建一个简单的投票工作人员与计时器从rxjs在反应应用程序。 为此，我创作了一部史诗。非常简单-我在1分钟内每5秒从服务器获取一些信息。
浏览 16提问于2020-09-29得票数 0
回答已采纳
我对该http请求只有很少的订阅，我希望在所有订阅完成后能够执行一个函数。 .subscribeOnCompleted(res => res.json); <-- this need's to be last}
外部库也有一些对请求的订阅
浏览 4提问于2016-03-22得票数 1
1回答
我是Rxjs/Observables的新手，它真的开始困扰我了。我使用了一个可观察对象来遍历方法，并确保在每个方法完成后逐个调用它们(使用next()函数)。那么，在假设所有5个next调用中的第二个调用某些数据出现问题后，如何取消整个订阅？下面是一个简化的示例代码，便于您了解情况。我正在导入以下数据：在构造函数中，我准备好我的Observable：
this.myObservable
浏览 5提问于2018-11-19得票数 1
你好，StackOverflowers，目的是在更新服务中存储的数据(数组或对象)时通知控制器。
浏览 0提问于2018-09-05得票数 0
回答已采纳
我有一个组件-A.ts文件，它有一个方法-A()，它从一个服务-B()调用一个方法-B()(我试图使它可观察到的方法，所以我不确定我是否做对了)，如下所示updateNursingUnitList(getUpdate: boolean) {
recipeObs.subsc
浏览 0提问于2019-06-14得票数 1
1回答
我们有一个无法完成的rxjs订阅。我想知道这是rxjs库中的错误，还是我们做错了什么。如果它没有关闭(并且它存在)，我们就取消订阅(这会立即关闭它)。然后，我们将其分配给来自this.lookupService.getGroupLookups()的新订阅。回调完成后，订阅应该关闭(对吗？)。我可以通过控制台在5秒超时内记录订阅的关闭状态来测试这一点。大约每5次中就有1次，表示订阅未关闭。
此方法可以在之前的观察值触发之前多次调用。例如
浏览 1提问于2021-11-15得票数 1
使用*ngFor，我无法将数据从我的component.ts获取到我的component.html
同一方法适用于一个类，但不适用于另一个类。
浏览 1提问于2021-09-29得票数 0
回答已采纳
我使用的是rxjs订阅。我得到了值，但是因为rxjs是异步的，所以函数在从服务器获取值之前返回。下面是一个伪代码，用来解释我要做的事情： ..
浏览 16提问于2020-04-06得票数 0
回答已采纳
2回答
我必须同时使用promise和observable。
我的前端使用Angular，在我的代码中，我必须使用JavaScript中的另一个库。我必须使用这个返回promise的JavaScript库创建许多请求。
浏览 8提问于2021-05-27得票数 0
回答已采纳
我有一个可以观察到的父值，一旦它有了订阅服务器，它就会执行一个查找并发出一个值，然后完成。我想把它转换成一个可观察的(或行为主体或其他有用的东西)，这样做如下:一旦它至少有一个订阅者，它就会从可观察的父用户那里得到结果(一次)。然后，当所有订阅者订阅时，它会向所有订阅者发出该值，并向所有未来订阅者发出该值。它应该继续这种行为，即使它的订户计数下降到零。.take(1)
.subscribe( value => theValue$.next(va
浏览 4提问于2017-09-13得票数 21
回答已采纳
我想截取流，获取值并将其设置为variable而不订阅。我尝试使用管道和地图操作符，但不起作用。做这件事最好的方法是什么？import { Observable, of } from 'rxjs';import { map} from 'rxjs/operators';@Injectable({
prov
浏览 30提问于2020-07-19得票数 3
回答已采纳
完成一个http请求，当完成该请求时，将使用该值调用BehaviorSubject.next方法。此值可以在单个页面的生命周期中更改。我想要的是订阅者必须等待http请求完成(延迟)，并在完成http请求并设置值时获取值。我将如何使用rxjs实现这一点？
另一个要求是，如果我在一种方法中订阅<
浏览 0提问于2018-03-22得票数 4
回答已采纳
因此，我希望在工作中使用ReactiveX (特别是RxJava和RxJS)，在这里，我正在开发一个应用程序，该应用程序实质上接收来自服务器的“更新流”，并将其显示给用户(经过一些操作)。在我看来，就反应性流命名而言，我的应用程序是订阅发行者以接收感兴趣的值的“订阅者”。虽然我有一些疑问，但这使我无法在工作中使用RxJava：
--在我的例子中，"Publisher“是另一个服务(它不使用RxJava之类的)，我不控制或维护，因此，我不能更改它的代码来实现"Publi
浏览 1提问于2021-01-07得票数 0
回答已采纳
我必须在我的angular 2项目中使用Websocket连接。
浏览 2提问于2018-12-18得票数 0
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
