我是一個noobie with observables,我試圖創建一個可觀察的點擊流來忽略雙擊時發生的2個點擊事件,但我得到這個錯誤: -爲什麼我得到緩衝區不是函數錯誤
Unhandled Promise rejection: this.clickStream.buffer is not a function ; Zone: <root> ; Task: Promise.then ; Value: TypeError: this.clickStream.buffer is not a function
,我不明白爲什麼。
的代碼如下: -
import {Component, NgModule} from '@angular/core';
import {BrowserModule} from '@angular/platform-browser';
import {Subject} from 'rxjs/Subject';
import {Observable} from 'rxjs/Observable';
@Component({
selector: 'my-app',
template: `
<div>
<button (click)="clickStream.next(1)">Click me!</button>
</div>
`,
})
export class App {
clickStream: Observable<number> = new Subject<number>();
singleClick;
constructor() {
this.singleClick = this.clickStream.buffer(() => this.clickStream
.debounce(250))
.map(arr => arr.length)
.filter(len => len != 2);
this.singleClick.subscribe(console.log.bind(console));
}
}
@NgModule({
imports: [ BrowserModule ],
declarations: [ App ],
bootstrap: [ App ]
})
export class AppModule {}
我一直在使用Angular + Typescript Demo Plunk
對此進行測試。
import'rxjs/add/operator/buffer'; ? – Maxime
通過導入所有操作符來消除錯誤,但是當按下按鈕時沒有任何反應。我有'codepen.io'中的類似的代碼工作正常,我試圖得到這個'angular/typescript'代碼的工作。 – user223364