Throttle the RxJs interval based on the inner observables

Question

Throttle the RxJs interval based on the inner observables

Sorry if the way I am asking this question is not clear, I am having difficulty finding the right words to explain it.

I am currently working on Selenium automation and here is how the process goes:-

Go to a specific page
Every 1 second, check if the page contains a certain element
If the element is found, refresh the page. If not, go back to step 2
Wait for the page to finish reloading before moving back to step 2

This is what I have come up with so far:

interval(1000)
.pipe(
 switchMap(() => from(driver.findElements(By.xpath("elementx"))),
 filter(([element]) => element), // stop emitting if element not found, wait for next interval
 switchMap(() => from(driver.navigate().refresh()))
).subscribe(() => {})

However, I want the interval to pause when the selenium driver is waiting for findElements or refresh. Which rxjs operators should I use to achieve this?

javascript selenium rxjs

Answer 1

Answer №1

Try implementing the exhaustMap operator in your code. Instead of placing the continuation outside of the exhaustMap, embed it within the operator (using an inner pipe). This will ensure that any new emissions are ignored until the entire process is complete, like in the example below:

interval(1000)
  .pipe(
    exhaustMap(() => {
      return from(driver.findElements(By.xpath("elementx"))).pipe(
        filter(([element]) => element),
        switchMap(() => driver.navigate().refresh())
      )
    })
  ).subscribe(() => { })

Note: Operators like switchMap, mergeMap, and concatMap can accept promises directly.

Answer 2

Try implementing the exhaustMap operator in your code. Instead of placing the continuation outside of the exhaustMap, embed it within the operator (using an inner pipe). This will ensure that any new emissions are ignored until the entire process is complete, like in the example below:

interval(1000)
  .pipe(
    exhaustMap(() => {
      return from(driver.findElements(By.xpath("elementx"))).pipe(
        filter(([element]) => element),
        switchMap(() => driver.navigate().refresh())
      )
    })
  ).subscribe(() => { })

Note: Operators like switchMap, mergeMap, and concatMap can accept promises directly.

Throttle the RxJs interval based on the inner observables

Answer №1

Similar questions

`In AngularJS, the same URL ('/') can display different templates depending on the user's login status.`

Is it possible to return true to asp.net OnClientClick following an Ajax request? Alternatively, is there another method that can be used?

What is the best way to find information in a multi-page table?

Working with Python and BeautifulSoup to retrieve <td> elements in a table without specified IDs or classes on HTML/CSS documents

Is there a different way to invoke PHP within JavaScript?

Retrieving search results in JSON format from a website with NodeJs

Vercel Alert: (Azure) Missing OpenAI API key

Tips for integrating Chart.js into my AngularJS application?

Verify whether the element retains the mouseenter event after a specified delay

Switch between accordion items

Get the MAC address of a client using Node.js

Unable to assign value to Ref data property in Vue3 due to undefined item

Differences between Angular's $injector and Angular's dependency injectionAngular

What is the proper way to utilize BrowserRouter when child routes are connected to components?

Ways to utilize a string as an object?

How to iterate through two arrays using AngularJS ng-repeat

What is the best way to include JavaScript in a web view within an Ionic Android application?

"Trouble with jQuery not being triggered when there is a string in

Is it necessary to create a unit test for a basic operation involving RxJS?

"Experience the power of MVC single page CRUD operations paired with dynamic grid functionality