javascript RxJS缓存和刷新AJAX方法

Posted 2021-05-03

fromCache('itemList')
.pipe(
  switchMap(itemList => (
    interval(3600000) // 1 hour
    .pipe(
      startWith(0),
      switchMap(() => (
        ajax({
          url: 'https://api.example.com/data',
        })
        .pipe(
          pluck('response'),
        )
      )),
      startWith(itemList),
      filter(Boolean),
      distinctUntilChanged(),
    )
  )),
)
.subscribe(itemList$)