0

rxjs 5.5.12我在 React Native 中使用代码，它可以工作。

在 rxjs 5.5.12 中：

// the function will return Observable
  rxInit() {
    return Observable.combineLatest(
      myObservable1,
      myObservable2,
    ).flatMap((result) => {
      console.log('rxInit result =>', result) // I can see the result
      const [token, email] = result

      this.token = token
      this.email = email

      // check the value is empty or not and return Observable.

      if (this.token != null && this.email != null) {
        return Observable.fromPromise(myApiPromise).catch(handleErrorFunction)
      } else if (this.token != null && this.uid != null) {
        return Observable.fromPromise(myApiPromise).catch(handleErrorFunction)
      } else {
        return Observable.of(null)
      }
    })
  }

在 rxjs 6.5.3 中：

首先导入一些操作员：

import { combineLatest } from 'rxjs';
import { flatMap } from 'rxjs/operators';

我更改代码：

rxInit() {
  console.log('rxInit start');

  return combineLatest(
    myObservable1,
    myObservable2
   ).flatMap((result) => {
     console.log('rxInit result =>', result)
   });

   console.log('rxInit end');
 }

它会显示错误TypeError: (0 , _rxjs.combineLatest)(...).flatMap is not a function。

所以我注意到可能是我必须使用pipe，我尝试更改代码。

rxInit() {
    console.log('rxInit start'); // it works.

    return combineLatest(
      myObservable1,
      myObservable2
    ).pipe(flatMap((result) => {
      console.log('rxInit result =>', result);  // the console log doesn't work
    }));
    console.log('rxInit end'); // the console log doesn't work
  }

我不知道为什么我无法在我的 console.log 中得到结果。

任何帮助，将不胜感激。

4

1 回答 1

2

看起来你没有从 flatMap() 返回任何东西，mergeMap 在 rxjs 中用于支持 flatMap btw。你需要返回一个可观察的。

return combineLatest(
  myObservable1,
  myObservable2
).pipe(mergeMap((result) => {
  console.log('rxInit result =>', result);  // the console log doesn't work
  return of(result)
}));
于 2019-10-30T07:30:58.737 回答