javascript - Angular 2观测值

我正在构建一个应用程序来从Facebook获取一些事件，请看一看：
事件组件：

events: Object[] = [];

constructor(private eventService: EventService) {
  this.eventService.getAll()
    .subscribe(events => this.events = events)
}

事件服务：

getAll() {
  const accessToken = 'xxxxxxxxxxx';
  const batch = [{...},{...},{...},...];
  const body = `access_token=${accessToken}&batch=${JSON.stringify(batch)}`;

  return this.http.post('https://graph.facebook.com', body)
    .retry(3)
    .map(response => response.json())
}

身份验证服务：

getAccessToken() {
    return new Promise((resolve: (response: any) => void, reject: (error: any) => void) => {
      facebookConnectPlugin.getAccessToken(
        token => resolve(token),
        error => reject(error)
      );
    });
  }

我有几个问题：
1）如何设置每隔60秒更新事件的间隔？
2）accessToken的价值实际上来自一个承诺，我应该这样做吗？

getAll() {
  const batch = [{...},{...},{...},...];
  this.authenticationService.getAccessToken().then(
    accessToken => {
      const body = `access_token=${accessToken}&batch=${JSON.stringify(batch)}`;
      return this.http.post('https://graph.facebook.com', body)
        .retry(3)
        .map(response => response.json())
    },
    error => {}
  );
}

3）如果是，我如何处理来自getAccessToken()承诺的错误，因为我只返回观察者？
4）post请求的响应在默认情况下不会返回一个对象数组，我必须进行一些操作。我应该这样做吗？

return this.http.post('https://graph.facebook.com', body)
  .retry(3)
  .map(response => response.json())
  .map(response => {
    const events: Object[] = [];
    // Manipulate response and push to events...
    return events;
  })

最佳答案

以下是您问题的答案：
1）你可以利用观测值的interval功能：

getAll() {
  const accessToken = 'xxxxxxxxxxx';
  const batch = [{...},{...},{...},...];
  const body = `access_token=${accessToken}&batch=${JSON.stringify(batch)}`;

  return Observable.interval(60000).flatMap(() => {
    return this.http.post('https://graph.facebook.com', body)
                    .retry(3)
                    .map(response => response.json());
  });
}

2）在这个水平上，你可以利用观测值的fromPromise函数：

getAll() {
  const batch = [{...},{...},{...},...];
  return Observable.fromPromise(this.authenticationService.getAccessToken())
                   .flatMap(accessToken => {
    const body = `access_token=${accessToken}&batch=${JSON.stringify(batch)}`;
    return this.http.post('https://graph.facebook.com', body)
                    .retry(3)
                    .map(response => response.json())
    });
}

3）您可以利用catch运算符处理错误：

getAll() {
  const batch = [{...},{...},{...},...];
  return Observable.fromPromise(this.authenticationService.getAccessToken())
                   .catch(() => Observable.of({})) // <-----
                   .flatMap(accessToken => {
    const body = `access_token=${accessToken}&batch=${JSON.stringify(batch)}`;
    return this.http.post('https://graph.facebook.com', body)
                    .retry(3)
                    .map(response => response.json())
    });
}

在这种情况下，当获取访问令牌出错时，将提供一个空对象来生成post请求。
4）当然！map运算符允许您返回所需的内容…