Как использовать объединение последнего с flatMap в rxjs6? - PullRequest
Новая
       81

Как использовать объединение последнего с flatMap в rxjs6?

0 голосов
/ 30 октября 2019

Я использую код с 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.

Любая помощь будетбыть оцененным.

1 Ответ

2 голосов
/ 30 октября 2019

похоже, что вы ничего не возвращаете из flatMap (), mergeMap используется в rxjs в пользу flatMap, кстати. Вам нужно вернуть наблюдаемое. 

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