我有一个表示无限数据源的observable，我希望用户以交互方式获取n项的页面(例如，单击next或使用无限滚动)。问题是，当我使用take()时，它也会取消对我的源代码的订阅，所以当我想要获取更多项目时，它会重新开始。我知道skip()，所以我可以快进，但是因为我的source会进行api调用，所以这样做的代价可能会很高(它在必要时会在幕后使用Observable.defer来获取页面)。(item)); // [1,2,3],
浏览 0提问于2018-01-31得票数 0
UPD:稍后我需要在函数外部使用数据，这就是我需要观察者的原因。myFun(a) {}
myFun(this.previousUrl);
浏览 0提问于2017-12-06得票数 0
我想知道，在映射通过调用let observable = subject.asObservable()创建的可观察到的内容时，是否对每个新缓冲区重新执行下面的组合。observable.map((nextThing) => { }).take(1)
如果Observable<string>的流和"Hey", "Jey" "Fley"一样，那么唯一的
浏览 2提问于2017-08-11得票数 1
回答已采纳
我一直收到一个错误，即取消订阅不是一个函数。我使用rxjs@5.0.0-beta.12。以下是我的重要陈述：import 'rxjs/add/operator/take';count
浏览 4提问于2016-09-30得票数 0
回答已采纳
1回答
我们创建了一个运算符函数，用于在组件被销毁时取消订阅。我们正在使用ng-take- are destroy库来帮助实现这一点。 在升级到Angular 6/7之前，它工作得非常好。import { Subscription } from "rxjs";import {unt
浏览 12提问于2019-04-26得票数 1
当最后一个主题观察者从主题中取消订阅时，AsyncSubject变得可观察。这是
const ofObservable = Rx.Observable.of(1, 2, 3);
在RxJS 5中，运算符share()使热的、可观察到的refCounted可以在失败
浏览 2提问于2017-07-14得票数 4
回答已采纳
7回答
如何将以下可观察到的承诺转换为一个承诺，这样我就可以用.then(...)**?**调用它 this._APIService.getAssetTypes().subscribe( this._LocalStorageService.setAssetTypes(assettypes); err => { }, );
它调用
浏览 8提问于2016-04-21得票数 88
回答已采纳
1回答
我想使用存在通道进入我的离子应用程序，以验证在应用程序中的任何时候，如果用户是否连接；import { PusherServicesService } from 'src/servicesconstructor( )
connectedUserObservable(): Observable
浏览 4提问于2022-01-21得票数 1
我对"dispose“或"unsubscribe”函数的用途感到困惑，它(可选)是从可观察的"executor“函数返回的，如下所示： obs.next('complete')
浏览 11提问于2017-01-06得票数 10
回答已采纳
我有以下服务来适应我的应用程序中的全局旋转器：import {} from '@angular/core'; Observableimport {} from 'rxjs/ReplaySubject';
export class< boole
浏览 6提问于2017-05-16得票数 1
回答已采纳
2回答
我想有一个观察值，当取消订阅时，它调用一个函数，但只有当它被取消订阅时，没有错误，没有完成。我正在尝试构建的可观察性通常会与另一个可观察性竞争。playback.ts import { timer } from "rxjs";importfunction finalFunc() {
console.log("fina
浏览 14提问于2019-05-04得票数 3
回答已采纳
如果在公共方法中使用而不是在ngOnDestroy中使用，则无法取消订阅。 } const pollingInterval: Observable<any> = observable.interval(3000).startWith(0);
浏览 0提问于2018-08-30得票数 0
我正在使用ngrx和angular。我有一个组件，它在模块'A‘中有一个下拉列表。在更改下拉列表时，我在ngrx存储中设置了选定的值。 return this.appStateManager.getFromStore(state我从appStateM
浏览 1提问于2017-10-04得票数 0
根据RxJS 5手册中关于的章节
...we可以使用ConnectableObservable的refCount()方法(引用计数)，它返回一个可观察的方法来跟踪它有多少订阅者。当订阅者的数量从0增加到1时，它将为我们调用connect()，这将启动共享执行。只有当订阅者数量从1减少到0时，才会完全取消订阅，从而停止进一步的执行。如果在使用refCount()运算符时无法做到这一点，请提供一个示例，说明如何使用自定
浏览 3提问于2017-07-18得票数 1
回答已采纳
我的理解是，整个数组被推送到订阅者，不像可以取消订阅/取消的间隔观察者。// emit a value every second for approx 10 seconds .take(10)// emit a rangele
浏览 1提问于2018-05-22得票数 0
回答已采纳
1回答
订阅方法获得多次调用角5
、、、、
我在ngOnInit of controller.ts中订阅了一种方法。在视图中，有一个选项可以从列表中选择不同的用户，该列表重定向到同一个页面，只需更改URL中的ID。因此，方法多次被订阅。但是，如果我在ngDestroy中使用取消订阅，那么它就不会在ngOnInit中再次获得订阅。是解决这个问题的方法。 this.{console.log(obj.text)} }
相同页面上的
浏览 0提问于2018-10-17得票数 1
回答已采纳
1回答
通常，我会在使用生命周期钩子( ngOnDestroy )的any ()调用时取消订阅任何打开的订阅。由于AppComponent是应用程序的根，因此从未被销毁(除整个应用程序被销毁时外)，是否仍然需要实现ngOnDestroy，是否需要从订阅中取消订阅？
浏览 3提问于2019-10-07得票数 9
回答已采纳
switchMap()将追逐它接收到的最新发射，并取消它以前正在执行的任何Observable。假设我翻转了它，当它忙于第一次发射时，我想忽略向xxxMap()操作员发出的所有排放。它将一直忽略排放，直到它完成释放当前的Observable在里面。然后，它将处理它收到的下一个发射。Observable.interval(1, TimeUnit.SECONDS)
.doOnNext(i -> System.out.println("Source Emitted Value在上面的例子中
浏览 0提问于2016-05-11得票数 11
回答已采纳
5回答
在我的角5应用程序中，需要在应用程序的不同位置多次使用特定的数据集(而不是经常更改)。调用API之后，结果将使用可观察的do操作符存储。通过这种方式，我在服务中实现了HTTP请求的缓存。我用的是角5.1.3和RxJS 5.5.6。import { HttpClient } from '@angular/commo
浏览 8提问于2018-04-12得票数 22
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
