可观察到角度rxjs。定时器不是具有导入功能的函数

Question

在我的angular应用程序中，我收到以下错误：

错误类型错误：rxjs_observable__webpack_imported_module_4__.observable.timer在switchmapsubscriber.project（hybrid.effect.ts:20)在switchmapsubscriber.push../node_modules/rxjs/_esm5/internal/operators/switchmap.js.switchmapsubscriber._next（switchmapsubscriber.js:34)在switchmapsubscriber.push./node_modules/rxjs/_esm5/internal/subscriber.js.subscriber.next（subscriber.js:54)在filter.js.filtersubscriber._next(filter.js:38)位于filtersubscriber.push../node_modules/rxjs/_esm5/internal/subscriber.js.subscriber._next(subscriber.js:54)位于SCANNEDActionsSubject.push./node_modules/rxjs/_esm5/internal/subscriber.js.subject.next(subject.js:47)位于SafeSubscriber._next(store.js:332)位于SafeSubscriber.push./node_modules/rxjs/_esm5/internal/subscriber.__trunsub(subscriber.js:195)在safeSubscriber.push../node_modules/rxjs/_esm5/internal/subscriber.js.safeSubscriber.next(Subscriber.js:133)在Subscriber.push../node_modules/rxjs/_esm5/internal/subscriber.js.subscriber._next(Subscriber.js:77)

我的代码如下所示：

import { Injectable } from '@angular/core';
import { Effect, Actions } from '@ngrx/effects';
import { of } from 'rxjs/observable/of';
import { map, catchError, switchMap } from 'rxjs/operators';
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/timer';

import * as hybridActions from '../actions/hybrid.action';
import { FleetStatusReportService } from '../../fleet-status-report.service';

@Injectable()
export class HybridEffects {
  constructor(
    private actions$: Actions,
    private fleetstatusreportService: FleetStatusReportService
  ) {}

  @Effect()
  loadHybrid$ = this.actions$.ofType(hybridActions.LOAD_HYBRID).pipe(
    switchMap(() => Observable.timer(0, 900000)),
    switchMap(() => {
      return this.fleetstatusreportService.getHybridPerformance().pipe(
        map(hybrid => new hybridActions.LoadHybridSuccess(hybrid)),
        catchError(error => of(new hybridActions.LoadHybridFail(error)))
      );
    })
  );
}

我一直在网上搜索，在我看来，最新的angular版本将使用

import 'rxjs/add/observable/timer';

然而，这似乎并不奏效。有人知道怎么解决这个问题吗？

Answer 1

如果您将最新的angular与RXJS6一起使用，那么您需要这样做：

import { map, catchError, switchMap } from 'rxjs/operators';
import { Observable, of, timer } from 'rxjs';

loadHybrid$ = this.actions$.ofType(hybridActions.LOAD_HYBRID).pipe(
  switchMap(() => timer(0, 900000)),
  switchMap(() => {
    return this.fleetstatusreportService.getHybridPerformance().pipe(
      map(hybrid => new hybridActions.LoadHybridSuccess(hybrid)),
      catchError(error => of(new hybridActions.LoadHybridFail(error)))
    );
  })
);

基本上，observable不再有monkey补丁，现在您需要从rxjs导入timer函数，然后使用它。

关于这一变化的更多信息请参见：