返回订阅期间从Observable发出的值的最新计数
这个问答内容涉及到RxJS中的概念，RxJS是一个用于处理异步数据流的库。在RxJS中，Observable是一个表示异步数据流的对象，它可以发出多个值，并且可以在订阅期间持续发出新的值。
针对这个问题，可以使用RxJS中的操作符来实现返回订阅期间从Observable发出的值的最新计数。其中，可以使用scan操作符来计算最新计数，并使用startWith操作符来设置初始计数值。
以下是一个示例代码：
import { Observable } from 'rxjs';
import { scan, startWith } from 'rxjs/operators';
// 创建一个Observable对象，发出一系列数字
const source$ = new Observable(observer => {
let count = 0;
const interval = setInterval(() => {
observer.next(count++);
}, 1000);
// 在取消订阅时清除定时器
return () => {
clearInterval(interval);
};
});
// 使用scan操作符计算最新计数
const count$ = source$.pipe(
scan((acc, value) => acc + 1, 0),
startWith(0)
);
// 订阅最新计数的变化
const subscription = count$.subscribe(count => {
console.log('最新计数:', count);
});
// 取消订阅
setTimeout(() => {
subscription.unsubscribe();
}, 5000);在上述代码中，首先创建了一个Observable对象source$，它每秒发出一个递增的数字。然后使用scan操作符对这个Observable进行处理，计算最新计数。最后，订阅count$，并在控制台打印最新计数。在5秒后，取消订阅。
这样，就能够实现返回订阅期间从Observable发出的值的最新计数。
在腾讯云的产品中，可以使用云函数 SCF（Serverless Cloud Function）来实现类似的功能。通过编写云函数代码，可以监听某个事件源（如消息队列、定时触发器等），并在事件发生时执行相应的逻辑。在逻辑中，可以使用计数器来记录最新计数，并将其存储在云数据库中。具体的实现方式可以参考腾讯云函数 SCF 的文档和示例代码。
腾讯云函数 SCF产品介绍链接地址：https://cloud.tencent.com/product/scf
相关·内容
我需要确定两种处理可观测值的不同方法是否同样有效，或者其中一种方法是否会导致内存问题。
在下面的示例中，foo$和bar是从服务接收其值的模板变量。每个人都有自己的可观察性。在组件中，从订阅中显式地给出了bar的值，然后在OnDestroy()中结束该订阅。然而，foo$没有显式地订阅服务，而是在模板中使用async管道。
foo$和bar都是显示服务数据的有效方式，还是foo$有问题，因为没有取消对内存清理的订阅？
ExampleService:
Injectable()
export class ExampleService {
get foo$(): Observable<
浏览 2提问于2019-05-08得票数 3
回答已采纳
1回答
使用可观测值自动更新视图
、、、
我使用可观察和HTTP请求在服务器上添加数据，然后更新其他路由。
我希望这些数据能立刻更新。实际上，我应该刷新页面以获得新的数据。
在我的服务中，我使用AddProj()和getAllProj()函数来获取和发送数据
service.ts
import { Injectable } from "@angular/core";
import { NouveauProjet } from "./models/nouveau-projet";
import { HttpClient, HttpResponse } from "@angular/common/h
浏览 3提问于2017-12-22得票数 0
我看到了一些意想不到的结果，当使用combineLatest在一组寒冷的可观测数据。它从所有可观测到的所有元素中发出最新的，而不是将第一个(n-1)观测值中的最新数据与第n个可观测到的每个元素相结合。
let observable = ReplaySubject<Int>.createUnbounded()
let observable2 = ReplaySubject<String>.createUnbounded()
observable.onNext(1)
observable.onNext(2)
observable.onNext(3)
observable.
浏览 2提问于2020-11-02得票数 2
回答已采纳
我一直在做一个有棱角的项目。但我的项目不像它应该做的那样。我得到了错误" Error :无法找到“object”类型的不同的支持对象‘对象’。NgFor只支持绑定到诸如数组之类的Iterable。“在我页面的控制台里。
在我的页面上，我得到了“这件事”，但仅此而已。同时，我也应该看到我的'dier‘的'soort’。
在我的html中：
<p>This works</p>
<div
class="dier"
*ngFor="let dier of dieren$">
浏览 2提问于2020-05-19得票数 1
回答已采纳
我有一个使用NGRX的角形9应用程序，它大部分使用可观测/主题和assync管道。
我有一个导航栏组件，它具有以下HTML：
<ul class="navbar-nav">
<li class="nav-item" *ngFor="let menuItem of navbarMenuItems | async">
<a id="{{ menuItem.id }}" [routerLink]="menuItem.routerLink" class="nav-l
浏览 2提问于2020-03-06得票数 1
回答已采纳
我在找这样的东西：
let observable = PublishSubject<String>()
observable.onNext("1")
observable.onCompleted()
_ = observable.subscribeNext { s in
print(s)
}
因此，我希望在Observable完成后订阅它，并仍然获得值(或仅获得最后一个值)。
浏览 0提问于2016-09-12得票数 11
回答已采纳
2回答
我想用ngrx做一个语言管道。
component.html：
<p>{{1 | language: languageId | async }}</p>
语言管道：
constructor(private store:Store){}
transform(resourceId: number, languageId:number): Observable<string> {
return this.store.select(selectResource, { resourceId, languageId });
}
我的问题是，如果我更改了
浏览 5提问于2020-08-06得票数 2
回答已采纳
Observable.publish()和Observable.replay()返回ConnectableObservable。但是，当这些方法将接口作为参数(如Observable.publish(Func1)和Observable.replay(Func1) )时，它们将返回可观测的结果。
为什么他们返回可观察而不是ConnecatbleObservable？
如果我用那些带有参数的方法，我就可以观察到。然后我把submit(Observer)叫到了可观察的，可观察的就开始工作了。我不能调用connect()，因为可观测的是可观测的，而不是可观察的连接的。
如果我必须使用Observabl
浏览 2提问于2016-06-01得票数 1
回答已采纳
1回答
我有一个AuthService，它从Firebase获取Observable<auth>数据，并将其放入公共变量auth$中。
在我的应用程序中，我需要多个组件来访问这个auth$值来检查它的内容。
我目前只是在组件中做this.authService.auth$.subscribe(auth => this.auth = auth)。
是否意味着我要多次执行？
如果是，我应该将auth$定义为Subject/BehaviorSubject，在服务中订阅并使用.next**?**推送数据
浏览 0提问于2016-11-17得票数 2
回答已采纳
1回答
我希望将多个主题(fooSubject$、barSubject$)合并为一个可观测的(filterChanged$)，并在订阅合并可观测(filterChanged$)和其中一个值更改时返回(初始)值(_foo、_bar)。
我已经使用了BehaviorSubject (两个主题)，但是filterChanged$将在订阅时发出两次。在订阅可观察到的不使用_foo的filterChanged$时，如何立即返回值(filterChanged$、BehaviorSubject )
export interface IFilterData {
foo: string;
bar: st
浏览 1提问于2020-05-20得票数 2
回答已采纳
我有两个可以观察到的，我想知道最后一个发射的值。
示例：
private obs1: Observable<number> = interval(1000);
private obs2: Observable<number> = interval(700);
public lastValue; // should take the value of the last observable which emitted.
我找不到接线员来接这个。一种解决方案可以是订阅所有可观察到的内容，然后将lastValue作为主题并使用next更新其值，但我希望避免订阅所有可观察到
浏览 0提问于2019-07-24得票数 2
回答已采纳
当我开始学习角时，我阅读了博客，认为使用异步管道更好，因为它会自动从数据流中取消订阅。所以我知道
<div *ngIf="users | async">
<ul>
<li *ngFor="let user of users | async">{{ user.name }}</li>
</ul>
</div>
TS文件
export class AppComponent implements OnInit {
constructor(private htt
浏览 3提问于2020-11-25得票数 0
我正在尝试创建一个满足以下要求的observable：
1)当第一个客户端订阅时，则可观察对象需要连接到某个后端服务，并推送出初始值
2)当连续的客户端订阅时，则可观察对象应推出新值
3)当最终客户端部署时，观察者应断开与后端系统的连接。
4)后端服务也会定时调用OnNext，其他消息也会一起调用
到目前为止，我有一些类似于下面的东西。我不知道如何对每个订阅调用做出反应，而只是在最后的dispose中调用处理程序。
var o = Observable.Create((IObserver<IModelBrokerEvent> observer) =>
{
observ
浏览 1提问于2014-08-05得票数 1
2回答
Angular4 Rxjs尝试使用简单操作作为计数筛选结果，但是下面的代码返回Observable而不是数字
任何帮助都是非常感谢的。
Observable.from(myList).bla().filter(..).count();
回报是可观察的
浏览 0提问于2017-09-27得票数 0
回答已采纳
在这个角度应用程序中，我想在尝试登录之前等待加载一些数据。
首先，我用一个Subject实现了它，如下所示：
private _requiredDataLoadedSubject$: Subject<boolean> = new Subject();
private get _requiredDataLoaded$(): Observable<boolean> {
return this._requiredDataLoadedSubject$.pipe(
shareReplay({ refCount: true, bufferSize: 1 })
浏览 1提问于2020-09-16得票数 1
3回答
我理解异步管道在可观察的基础上工作，并帮助我们为稍后将要出现的数据加载事务异步。
但是，我也可以不用异步来工作。以下是代码
组件
export class XComponent{
someProp: string;
someList: string[];
someFn(){
this.someService.subscribe(
data=>{
this.someProp = data.prop;
this.someList =
浏览 4提问于2017-03-23得票数 3
1回答
我目前在前端使用角11，在后端使用Express。我正在尝试获取一个用户登录，以便我可以显示正确的标题。登录后，浏览器将我重定向到主页，并在浏览器中设置cookie，但标题中没有任何更改。在我单击注销按钮后，cookie就会被移除，并且标头保持不变。我试着使用chrome工具调试它，并记录isLogded$变量，但是它一直向我显示它是未定义的。我想我对BehaviourSubject.做了些错事
我真的希望有人能帮我找出我的错误，因为我刚开始的时候是棱角分明的。
为了得到更好的解释，我会附上一些文件。
auth.service.ts
import { HttpClient } from
浏览 1提问于2020-12-10得票数 0
回答已采纳
我有多个可观察到的值，它们在页面的生存期内发出值。例如：
chartData$: Observable;
tableData$: Observable;
filterData$: Observable;
在任何时候，用户都可以单击“下载”按钮，并获得JSON，并组合上一次从这些可观察到的值中发出的值：
downloadButtonClicked$.pipe(
combine chartData$, tableData$ and filterData$ // <- how do I get latest values here?
).subscribe(([chart, ta
浏览 2提问于2020-09-08得票数 2
回答已采纳
3回答
我有一个服务->
subject = new Subject<any>();
constructor (){
this.subject.next('hello');
}
getsubject():Observable<any>{
return this.subject.asObservable();
}
和组件->
name:string;
subscription : Subscription;
constructor(private serv:SService) {
this.subsc
浏览 0提问于2017-09-20得票数 12
回答已采纳
在许多情况下，我发现自己需要访问最近从可观察对象发出的值。我这样做的方式是订阅可观察的值并在它们出现时缓存它们。请参见下面的示例。然而，我看到有一堆方法，如Observable.MostRecent、Observable.Latest、Replay(1)等，它们似乎可以实现我正在寻找的东西，但我不知道如何使用它们。有没有比我下面使用的方法更好的方法？
public class WordPrinterWithCache
{
string _lastWord = string.Empty;
public WordPrinterWithCache(IObservable<st
浏览 6提问于2017-01-17得票数 2
回答已采纳
1回答
我以这种方式声明了一个类型记录界面：
export interface FolderList {
ADMIN: [Folder[], string, string];
SUPERADMIN: [Folder[], string, string];
USER: [Folder[], string, string];
}
文件夹以这种方式声明：
export interface Folder {
idFolder: number;
folderName: string;
}
我想要一个有三个数组的对象：
FolderList: {
ADMIN: [[{idFolder: '
浏览 2提问于2020-10-25得票数 1
回答已采纳
3回答
我不知道到底出了什么问题，但我正在尝试应用的搜索系统，但没有成功。
以下是组件中使用的函数：
// my-comp.component.ts
public testing: Observable<any>;
private searchTerms = new Subject<string>();
search(term: string): void {
this.searchTerms.next(term.toUpperCase());
}
每当我在搜索框中输入某项内容时，这个函数就会被击中，所以这里没有问题。
下面是ngOnInit方法：
// my-com
浏览 9提问于2017-06-20得票数 2
回答已采纳
1回答
我在试着创造一个可以观察到的热区。这意味着，当我有一个观察者在某个超时后观察到可观察对象时，它不应该接收到已经发布的值。我创建了以下程序：
import Rx from "rxjs/Rx";
var x = Rx.Observable.range(1,10).share()
x.subscribe(x => {
print('1: ' + x);
});
setTimeout(() => {
x.subscribe(x => {
print('2: ' + x);
});
}, 1000)
浏览 1提问于2018-07-04得票数 2
2回答
这个rxjs合并逻辑可以简化吗？
、、、、
我从Firebase客户端获得了一个可观察的(onAuthStateChanged)，即：
如果用户没有登录，会立即发出null，而会在几分钟后发出null，然后在用户登录时发出user object。
const observable = new Observable((obs) => {
return app.auth().onAuthStateChanged(
obs.next,
obs.error,
obs.complete
)
})
我想要的是：
accepted)always 忽略应用生命周期前1000 is发出
浏览 3提问于2021-08-09得票数 3
回答已采纳
在这里，我试图将一个id从component1传递给我的服务，并且我使用这个主题在服务中发出这个id。我正尝试从component2订阅这个主题以获得id。但我没能拿到身份证。
component1
export class ContestUploadButtonComponent implements OnInit {
contestId:any
ngOnInit(): void {
this.contestId = this.contest
this.frontEnd.contestDa
浏览 10提问于2022-10-24得票数 0
我不明白以下文档在这个中意味着什么。有人能回答吗？
结果是，switched本质上是一个计时器，每次点击都会重新启动。从较旧的单击中可观察到的间隔不与可观察的当前间隔合并。
以下是代码：
var clicks = Rx.Observable.fromEvent(document, 'click');
// Each click event is mapped to an Observable that ticks every second
var higherOrder = clicks.map((ev) => Rx.Observable.interval(100
浏览 2提问于2017-03-31得票数 3
回答已采纳
我有一个问题，角2/4，并得到一个(S)的具体路线。我这样做了上百次，从来没有遇到过这样的问题，从我在路由上调用的代码中可以看出，paramMap只运行了一次，但不知怎么的，它最终被调用了两次。
这就好像paramMap发出的值是相同的两倍而不是一倍。问题是，通过这种方式，我向服务器发出两个请求，发送重复的数据。
export class UserComponent implements OnInit {
user: User;
submitted: Observable<Topic[]>;
constructor(
private rou
浏览 4提问于2017-08-25得票数 3
回答已采纳
1回答
当我的服务调用返回HTML页面的数据时，使用异步绑定与只映射到具体对象有什么好处或好处？
下面是这两个选项的一个例子。
映射到组件属性
// component
event: any;
// ngOnInit()
this.eventService.getEvent(this.id).pipe(take(1)).subscribe(response => {
this.event = response;
}, error => {
console.log(error);
});
// service
getEvent(id: number): Observable&
浏览 1提问于2021-12-03得票数 1
1回答
我在试着理解可观察性。当我使用交换机运算符时，我无法理解“它取消了以前可观测到的和新的一条”这句话。
var inp=document.getElementById("i");
var t=Rx.Observable.fromEvent(inp,"keyup");
t.map((e)=>Rx.Observable.range(1,3)).subscribe((e)=>console.log(e))
///t.map((e)=>Rx.Observable.range(1,3)).switch().subscribe((e)=>console
浏览 0提问于2019-03-23得票数 3
回答已采纳
1回答
我有2个BehaviorSubjects和2个可观测到的：
private payments = new BehaviorSubject(<Payment[]>[]);
payments$: Observable<Payment[]> = this.payments.asObservable();
private purchases = new BehaviorSubject(<Purchase[]>[]);
purchases$: Observable<Purchase[]> = this.purchases.asObservable();
浏览 1提问于2018-03-26得票数 0
回答已采纳
我有一个简单的用例：
收到事件通知
对事件执行一些操作
在x间隔后打印内容
如何在一个Rx管道中完成上述步骤？
如下所示：
void Main()
{
var observable = Observable.Interval(TimeSpan.FromSeconds(1));
// Receive event and call Foo()
observable.Subscribe(x=>Foo());
// After 1 minute, I want to print the result of count
// How d
浏览 4提问于2015-07-04得票数 0
回答已采纳
2回答
下面是可以在上运行的Angular组件的代码
@Component({
selector: 'my-app',
template: `
<div *ngIf="currentNumber$ | async as currentNumber">
<b>{{currentNumber}}</b>
</div>
<form [formGroup]="simpleForm">
<input type="number" formContr
浏览 0提问于2018-02-06得票数 1
2回答
我正在开发我的第一个Angular 2产品。我创建了这个Observable.timer，然后订阅了它。它轮询服务器上的数据。
如何暂停和取消暂停？
ngOnInit(): void {
this.poll = Observable.timer(500,500).subscribe((t: any) => {
this.request.getRackList(+this.global.zoneId).subscribe(
incoming => this.import(incoming),
err => { this.g
浏览 2提问于2017-02-08得票数 3
回答已采纳
2回答
对可观察服务的不需要的订阅
、、、、
按照缓存的服务模式，我使用订阅的BehaviourSubject，方法是在各种组件中使用从它创建的只读Observable
// credential.service.ts
private _credentialList$: BehaviorSubject<Credential[]>
readonly credentialListObv$: Observable<Credential[]>
...
this. credentialListObv$ = this.credentialList$.asObservable()
...
getCredentialList(
浏览 4提问于2021-09-07得票数 2
回答已采纳
我有一个角度项目，我的目标是显示某些数据取决于何时用户登录或未登录。我正在使用，但我一直收到这个错误Error: InvalidPipeArgument: '[object Object]' for pipe 'AsyncPipe'，这是我的auth.serveice相关部分：
private currentUserSubject: BehaviorSubject<User>;
private user = new Subject<any>();
public currentUser: Observable<User>;
pu
浏览 0提问于2020-12-28得票数 0
假设我有以下代码：
Observable.error(new Throwable()).
retryWhen(notificationHandler -> Observable.never()).
subscribe(x -> {}, t -> log("error"), () -> log("completed"));
我期望，它将保持执行，因为retryWhen永远不会重新提交到或完成。
但当我运行它时，应用程序停止了，甚至没有指示错误或竞争。
为什么它永远不会存在？
附言:我有这样的想法，那就是执行中断，因为它都运行
浏览 1提问于2017-05-16得票数 0
你好，我尝试缓存http请求，但是.next()操作符如果cache存在于local storage中就不能工作，下面是我的代码示例
const APP_DATA = `app_data`;
const APP_VERSION = `app_version`;
@Injectable({ providedIn: `root` })
export class AppService {
private _subject = new Subject();
public appData$: Observable<any> = this._subject.asObserv
浏览 0提问于2021-03-02得票数 0
回答已采纳
在下面的代码行中，我期望每2秒打印一次here。但是没有任何东西被印刷出来：
Rx.Observable.interval(1000).debounceTime(2000).subscribe(x => console.log('here'))
但是，在下面的代码行中，here按预期每2秒打印一次：
Rx.Observable.interval(2000).debounceTime(1000).subscribe(x => console.log('here'))
在第一种情况下，我预计1秒周期的事件流将被弹出为2秒周期。这似乎行不通。
在第二种情况
浏览 0提问于2018-03-07得票数 1
回答已采纳
2回答
在我的角+ RxJS应用程序中，我有一个有点复杂的管道结构：
remote-data.service.ts:
getAll(url): Observable<any[]> {
return this.http.get(url, this.options)
.pipe(map((result: any[]) => result));
}
proxy.service.ts:
// localDataService use my LocalDataService
// remoteDataService use my RemoteDataService
getAll(
浏览 3提问于2020-05-31得票数 4
回答已采纳
我在用
RxSearchView.queryTextChangeEvents
要检测“搜索时键入”以及提交搜索时的事件，SAYT将得到建议，而当您提交时，它将执行一个完整的搜索。
我目前有两个问题。
当您键入并获取建议时，突然单击submit执行完整搜索，但问题是，如果有正在进行的建议请求，则可能会出现在屏幕上的情况，因为完全搜索具有优先级。
因此，我想取消(取消订阅)的要求，从建议，如果有一个提交的完整搜索。
如何用这段代码实现这一点？
另一个问题是，当我删除搜索视图中的搜索词而它变得空时，它会清除适配器，但是当我清除搜索文本时，仍然会有一个正在进行的建议请求，它设置了结果，但是非常
浏览 2提问于2016-12-04得票数 0
回答已采纳
我在忙着用可观察的方法来解决问题
我有下一个代码：
public save(): any {
var that = this;
try {
debugger;//1
return new Observable((observer) => {
observer.next("123");
debugger; //2
})
} catch (e) {
浏览 1提问于2019-12-09得票数 1
回答已采纳
1回答
从活着的对象中创建可观察的对象
、、、、
我是RxJS的新手。我想要创建一个可以观察到的AppState对象，该对象可能在任何时候发生变化，并订阅它以获得这些更改。这是一个被剥离的实现：
export class AppState {
public get observable(): Observable<any> {
return Observable.of(this._state);
}
}
// appState is injected into my component via angular DI
this.appState.observable
.subscribe((app
浏览 5提问于2017-09-22得票数 0
回答已采纳
我想知道这两个函数之间是否有什么区别：
function testObservable(message: string) : Observable<string>{
return new BehaviorSubject(message);
}
function testObservable(message: string) : Observable<string>{
return of(message);
}
我在AsyncValidatorFn中返回一个AsyncValidatorFn，我得到了不同的行为，如果我返回of(T)
更新-验证代
浏览 3提问于2019-10-24得票数 0
回答已采纳
我在组件中定义了一个可观察的(结果$)，并通过异步管道在其模板上显示它。可观测性是通过combineLatest进行的其他两个可观测数据的组合(第一个$，第二个$)。如果其中一个可观测到的，或者两者都发布得太早(在我发现ngAfterContentInit之前)，那么可观察到的结果就不会发出一个值。
组件:不工作
@Component({
selector: 'my-app',
templateUrl: './app.component.html',
styleUrls: [ './app.component.css' ]
})
ex
浏览 0提问于2019-02-07得票数 7
回答已采纳
2回答
我需要从我的状态中获取ID作为单独的Observable，将它们组合到一个Observable中并对其执行subscribe()。我需要我的订阅者最终会得到一个解析的Observable结果数组。
此外，我需要保持此订阅打开，因此，如果我的内部Observable之一的变化，我的订阅者将被通知。
这是我的代码：
getTransactionsByIDs(transactionsIDs){
return Observable.of(transactionIDs
.map(transactionID => this.getTransactionByID(transactionID)));
浏览 0提问于2018-01-17得票数 12
回答已采纳
1回答
基于两个观测值的角度保护
、、、
我正在尝试做一个"AdminGuard"，它应该基于两件事：
是用户登录了吗？用户有管理权限吗？
我有一个AuthService，它提供两个Observable。
我做了以下工作：
@Injectable({
providedIn: 'root'
})
export class IsAdminGuard implements CanActivate {
constructor(private auth: AuthService, private router: Router) { }
canActivate(
next: Activate
浏览 2提问于2021-08-25得票数 1
回答已采纳
1回答
什么是getStickyEvent()与EventBus在RxJava中的等效。
我想订阅从“屏幕”观察到的不是在前台/不活动，但在任何时候非常可能会出现。
如果事件不断发生，我希望这些“屏幕”下次活动/在前台时接收它们。
编辑：
这听起来我应该有一个replaySubject，然后当“屏幕”到前台时，把它描述成……？
BehaviorSubject – emits the last emitted item when subscribed to,
then continues to emit items from the source observable
浏览 10提问于2014-09-24得票数 2
回答已采纳
我正在尝试从可观察对象中提取最后一个发射值。但是rxJS有两个运算符和。
rxJS中的last运算符和publishLast运算符有什么区别？
浏览 0提问于2019-05-09得票数 1
我很难理解如何使用RxJava构建缓存。我的想法是，要么从内存缓存获取数据，要么从我的数据库(dynamoDb)加载数据。但是，这个缓存应该在片段和或线程之间共享。因此，我需要返回当前正在运行且尚未完成的现有可观测数据。这使得线程能够赶上而不是做不必要的工作。我是RxJava新手，所以这就是我想要的草图(缺少一些简洁的代码)：
public class DBCache<K, T> {
private final ConcurrentHashMap<K, Set<T>> resultCache = new ConcurrentHashMap<>;
浏览 4提问于2015-12-29得票数 3
回答已采纳
我正在开发一个Range6应用程序，我想在localStorage中存储常用但很少改变的对象数组。我有一个服务类，用于从web服务中检索这些数组。服务中的函数返回可观测值。我想检查一下localStorage，看看数组是否已经存在。如果不是，那么我希望从web服务获取数组，并将localStorage项设置为返回的值。如果它已经存在，只需返回存储的内容。我很难从这个条件的所有可能分支中返回一个可以观察到的。好像有人已经做过的事，但我找不到任何例子.
下面是我返回其中一个数组的现有函数：
getApprovalRoutes(): Observable < ApprovalRoute[]
浏览 0提问于2019-01-10得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
