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

How can I apply a class to a list item when clicked using Vue.js and a template component generated by v-for loop?

Simulating dynamic route parameters in the Next 13 application directory

The search feature on mobile devices is currently malfunctioning

Creating a Client-side Web Application with Node.js

When using REACT to fetch data from an API, the absence of an 'Access-Control-Allow-Origin' header may result in access issues

Modal containing Jquery GalleryView

Enhancing TypeScript - Managing Variables within Namespace/Scope

Guide on sending JSON data to a server and receiving JSON/XML in response with JSP

Tips for enabling/disabling a Chrome extension through the utilization of local storage in the background page

Navigating through sections in NextJS-14: Utilizing useRef for seamless scrolling

A step-by-step guide on creating an xpath for an element by using another element with Selenium WebDriver

Node.js encountering difficulty extracting JSON data

Executing multiple MSSQL queries in a Node.js environment

Designing an interactive HTML table that adapts to various screen

What is the best way to reorganize an object's properties?

Tips for refreshing the default style of Material UI select

How can I switch out an item within FabricJS?

Vite and Transloadit encountered a type error: Unable to access properties of undefined when trying to read 'Resolver'

Strange actions observed in AJAX POST request

What exactly does the symbol "++" signify in the context of jQuery and JavaScript