Typescript implementation of a debouncer using rxjs Observable

Debouncer.ts

import { Observable } from "rxjs/Observable";
import { Observer } from "rxjs/Observer";

import "rxjs/add/operator/debounceTime";

/**
 * Class representing a debouncer to delay incoming events. 
 */
export default class Debouncer<T> {
  private observer: Observer<T>;

  /**
   * Creates a debouncer. 
   * 
   * @param  {(data: T) => void}  debounced     The method to call when the event is debounced. 
   * @param  {number}             debounceTime  The time to debounce the event. 
   */
  public constructor(debounced: (data: T) => void, debounceTime: number) {
    let observable = new Observable<T>((observer) => {
      this.observer = observer;
    });

    let subscription = observable.debounceTime(debounceTime).subscribe((data) => {
      debounced(data);
    });
  }

  /**
   * Update the debouncer's event's value. 
   * 
   * @param  {T}  data  The value to assign to the debouncer. 
   */
  public update(data: T) {
    this.observer.next(data);
  }
}