BehaviorSubject subscription with debounce

user_7628177 0
Viewed 869

I have BehaviorSubject property

public results$ = new BehaviorSubject(null);

Lets'say I have a subscription to this

this.results$.subscribe(() => this.find());

Subscription in being invoked each time when I press any key on keyboards inside input element. So, to prevent many requests to the server, I added debounceTime()

this.results$
   .pipe(debounceTime(500))
   .subscribe(() => this.find());

But I need to invoke the first this.find() without any debounce, just immediately.

How can I do that?

behaviorsubject rxjs angular
1 Answers

I would suggest you to use throttleTime instead of debounceTime. It propagates the first value and then wait for the specified amount of time.

Also change the BehaviorSubject to Subject.

public results$ = new Subject();

this.results$
   .pipe(
         filter(value => !!value && value.length >= 3),
         throttleTime(500))
   .subscribe(() => this.find());

Please read about throttleTime, auditTime and debounceTime here - https://rxjs-dev.firebaseapp.com/guide/operators

user_105786380
Related