代码之家 › 专栏 › 技术社区 › Florian Moser

在恢复之前等待RxJs.Subscription

rxjs

Florian Moser · 技术社区 · 6 年前

如何在恢复方法之前等待订阅完成?

让我们有一个 SettingService 它从服务器获取一次设置,然后缓存它们。它提供了一个 get(key): Setting 方法,并确保只有一个具有相同密钥的设置实例存在。这有两个含义:

它必须确保设置只下载/缓存一次

到目前为止我所拥有的:

export class SettingService {
    private settings: Setting[] = [];
    private settingSubscription: Subscription;
    private settingLoaded: Boolean = false;

    constructor(private http: HttpClient) {
        this.initSettings();
    }

    private initSettings() {
        this.settingSubscription = this.http.get<Setting[]>('api/Setting').subscribe(s => {
            this.settings = s;
            this.settingLoaded = true;
        });
    }

    get(key: string): Setting {
        if (!this.settingLoaded) {
            //TODO: wait for settingSubscription to finish
        }

        return this.resolveSetting(key);
    }

    private resolveSetting(key: String) {
        //uses this.settings to retreive the setting
    }
}

Wait on RxJs.Subscriptions to finish before resuming

1 回复 | 直到 6 年前

Oles Savluk 6 年前

如果你遵循“反应咒语”,你的问题就会得到解决:

看见 The introduction to Reactive Programming you've been missing

有了这个想法 Settings

const { timer } = rxjs; // = require("rxjs")
const { map, mapTo, shareReplay } = rxjs.operators; // = require("rxjs/operators")

// emulate making ajax request
function loadSettings() {
  console.log('request to load settings ...');

  return timer(2000).pipe(
    mapTo({
      a: 'a-value',
      b: 'b-value'
    })
  );
}

// Settings service
const settings$ = loadSettings().pipe(
  shareReplay(1) // cache result
);
const get = key => settings$.pipe(
  map(s => s[key] || 'default')
);

// usage example
get('a').subscribe(v => console.log("result for a: ", v));
setTimeout(
  () => get('unknown').subscribe(v => console.log("result for unknown:", v)), 
  5000
);

<script src="https://unpkg.com/rxjs@6.3.3/bundles/rxjs.umd.min.js"></script>

作为总结:

整个应用程序订阅一次就足够了

推荐文章

Ole · 在使用新的Angular Resource API时取消搜索术语?

7 月前

koque · 为什么我的RxJs主题没有按预期工作?

7 月前

Raphaël VO · 不使用Observable的初始值

7 月前

xarielah · 从app.config.ts调用时,BehaviorSubject不会更新

11 月前

Lenni · 返回信号并在Angular中订阅它

12 月前

dman · 在Angular单元测试中似乎无法模拟行为主体

1 年前

Nevyan Dimitrov Neykov · 效果内部的角度信号()

1 年前

Ð¤ÐµÐ´Ñ Ð Ð°Ð²ÑÐµÐµÐ² · 如何在react-js中使用Date()在后台增加变量?

1 年前

Ryley38 · 如何跳过流的第一个值,除非它是RxJS的复制粘贴?

1 年前

techwestcoastsfosea · Angular 18-RxJS:Subscribe已弃用[重复]

1 年前