HTML：
< input #search(input)=“generateSuggestions($event.target.value)”>

TS：

import { Jsonp,Response } from 'angular2/http';
import { Observable } from 'rxjs/Observable';
import { Subject } from 'rxjs/Subject'
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/debounce';
import { Injectable } from 'angular2/core';

@Injectable()
export class SearchService {
    queryStream = new Subject();

    generateSuggestions(query: string) {
        this.queryStream.onNext(query)
            .debounce(500)
            .map(
                query => this.jsonp.request( `http://urlendpoint/${query}` )
                        .map( (res: Response) => res.json() )
                        .subscribe( results => console.log(results) );
            )
    }
}
var queryStream = new Subject();

ORIGINAL EXCEPTION：TypeError：this.queryStream.onNext不是函数

我的所有普通http函数都工作(this.jsonp.request(url / query).map().subscribe())但是onNext运算符不起作用.我也无法导入flatMap,它似乎与map和debounce不在同一个’rxjs / add / operator / …’文件夹中.