Call asynchronous operations in RxJS operators

Question

With the code below I get a value every 500ms and I take 10 of them.

Now I want to filter out invalid values but the function I want to call is asynchronous (but happens very quickly) and I don't know how to do that in the filter operator.

this.subscription = this.input.getStream()
    .throttleTime(500)
    .filter(value => {
      // I want to filter out invalid values
      // but the function I want to call here is async
    })
    .take(10)  // and get 10 valid ones
    .subscribe(value => {
      this.values.push(value)
    })

Note: I want the filter to happen after the time throttling.

Possible duplicate of Is there an "async" version of filter operator in RxJs? — jonrsharpe
– jonrsharpe, Commented Feb 19, 2018 at 23:19

jonrsharpe · Accepted Answer · 2018-02-19 23:13:59Z

3

One way to do this is to:

use flatMap to call the async function, returning both the value and the result to be used for filtering;
filter based on the latter; then
at some later point, unwrap the value again.

In your case, maybe something like:

this.subscription = this.input.getStream()
    .throttleTime(500)
    .flatMap(value => asyncFunction(value).map(include => ({ value, include }))
    .filter(({ include }) => include)
    .take(10)
    .subscribe(({ value }) => {
      this.values.push(value)
    })

answered Feb 19, 2018 at 23:13

jonrsharpe

123k31 gold badges277 silver badges488 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

Call asynchronous operations in RxJS operators

1 Answer 1

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related