Doron Sever's snippet for rxjs post

preventDDOS.ts

private myStream = new Subject();
private myStream$ = this.myStream.asObservable();

ngOnInit() {

  // Will only fire after 100 ms.
  this.myStream$
    .pipe(auditTime(100))
    .subscribe(e => console.log('will only fire after 100 miliseconds');
  
  this.myStream.next(); // Fire it once
  setTimeout(() => {this.myStream.next();}, 10); // Fire it twice
}