Angular Pipe to transform value or value$ -> debounced (def 150ms) observable USAGE <cmp [prop]= "value | debounce | async"></cmp>

debounce.pipe.ts

import { OnDestroy, Pipe, PipeTransform } from '@angular/core';
import { BehaviorSubject, Observable } from 'rxjs';
import { debounceTime } from 'rxjs/operators';

@Pipe({ name: 'debounce', pure: true })
export class DebouncePipe implements PipeTransform, OnDestroy {
  private _bs: BehaviorSubject<any>;
  private _obs: Observable<any>;
  private _old: any;

  transform(value: Observable<any> | any, debounce: number = 150) {
    if (this._old !== value) {
      this._old = value;
      if (value instanceof Observable) {
        this.safeClearBS(); // DISTRUGGO L'EVENTUALE BehaviorSubject INTERNO NON MI SERVE PIU'
        // SE MI ARRIVA UN OBSERVABLE, SEMPLICEMENTE GLI AGGANCERO' debounceTime
        return (this._obs = value.pipe(debounceTime(debounce)));
      } else {
        // ALTRIMENTI SE MI ARRIVANO VALORI NORMALI (NON OBSERVABLE) ALLORA USO UN BehaviorSubject
        // PER EMETTERE I VALORI CHE MI ARRIVANO E POI LO RITORNO COME OBSERVABLE + debounceTime
        if (!this._bs) {
          // SE E' IL PRIMO VALORE CHE ARRIVA CREO AL VOLO IL BehaviorSubject INTERNO
          this._bs = new BehaviorSubject<any>(value);
        } else {
          // SE INVECE L'AVEVO GIA' CREATO SEMPLICEMENTE EMETTO IL VALORE CHE ARRIVA
          this._bs.next(value);
        }
        // RITORNO SEMPRE UN OBSERVABLE CON debounceTime IN MODO DA IGNORARE CAMBIAMENTI VELOCI
        return (this._obs = this._bs.pipe(debounceTime(debounce)));
      }
    } else {
      // SE MI ARRIVA STESSO OGGETTO RITORNO VECCHIO OBSERVABLE GIA' CREATO CON debounceTime
      return this._obs;
    }
  }

  private safeClearBS() {
    // COMPLETO IN MANIERA PULITA L'EVENTUALE BehaviorSubject INTERNO E POI LO DISTRUGGO
    if (this._bs) {
      this._bs.complete();
      this._bs = null;
    }
    this._obs = null;
    this._old = undefined;
  }

  ngOnDestroy() {
    this.safeClearBS();
    console.warn('DESTROY');
  }
}