Angular2 Timeout оператор не работает на расширенной Http

Когда я расширяю Http класс для добавления установщика тайм-аута с использованием rxjs, timeout оператор не работает, когда я импортирую это так import 'rxjs/add/operator/timeout'

Работает только когда я загружаю всю библиотеку rxjs

живи плнкр

import {Component, NgModule} from '@angular/core'
import {BrowserModule} from '@angular/platform-browser'
import {Observable} from 'rxjs/Observable'
import 'rxjs/add/operator/timeout'
import {HttpModule, RequestOptions, XHRBackend} from "@angular/http";

import {WpHttp} from "../wpHttp";

@Component({
  selector: 'my-app',
  template: `
    <div>
      <h2>Hello {{name}}</h2>
    </div>
  `,
})
export class App {
  name:string;
  constructor(private wpHttp: WpHttp) {
    //this.name = 'Angular2'
  }

  ngOnInit(){
    this.wpHttp.get("../test.json").subscribe((res)=>{
      this.name = res.title;
    });
  }
}

@NgModule({
  imports: [ BrowserModule, HttpModule ],
  declarations: [ App ],
  providers: [
    {
      provide: WpHttp,
      useFactory: (backend: XHRBackend, defaultOptions: RequestOptions) =>
        new WpHttp(backend, defaultOptions),
      deps: [XHRBackend, RequestOptions]

    }
  ],
  bootstrap: [ App ]
})
export class AppModule {}

Расширенная Http

import {Injectable} from '@angular/core';
import {Http, RequestOptions, RequestOptionsArgs, ConnectionBackend} from '@angular/http';

import {Observable} from 'rxjs/Observable';


@Injectable()
export class WpHttp extends Http {

  constructor(backend: ConnectionBackend,
              defaultOptions: RequestOptions) {
    super(backend, defaultOptions);
  }


  get(url): Observable<any> {

    console.log("started")
    return super.get(url)

      .timeout("500", new Error('delay exceeded'))
      .catch((err) => {
        return Observable.throw(err);
      })
      .finally(() => {
        console.log("finished")
      });
  }


}

1 ответ

Решение

Это исправлено добавлением всех используемых операторов

import 'rxjs/add/operator/timeout';
import 'rxjs/add/operator/catch';
import 'rxjs/add/operator/finally';
import 'rxjs/add/operator/map';
import 'rxjs/add/observable/throw';
import {Observable} from 'rxjs/Observable';
Другие вопросы по тегам