I am getting crazy with an issue regarding Vue with vue-rx I tried to apply a debounce that takes the first value in a time span

Hello, how are you?
I am getting crazy with an issue regarding Vue with vue-rx
I tried to apply a debounce that takes the first value in a time span
 

 beforeCreate() {

      const increment$ = this.$fromDOMEvent('.increment', 'click')

        .pipe(

          tap(() => console.log(":))!!")),

          exhaustMap(()=>interval(1000).pipe(map(x=>x)))

        );

      increment$.subscribe();

    }

 
That did not work
and not even this
 

const counterActions: ICounterActions = {

  incrementAsync ({ commit }) {

    // setTimeout(() => {

    //   commit(counterMutationTypes.increment)

    // }, 0)

    let subject$ = null;

    if(subject$ == null)

    {

      subject$ = new ReplaySubject();

      console.log('IS NULL')

    }



    from(subject$)

      .pipe(

        concatMap(val=> of(val).pipe(delay(2000))),

        exhaustMap (

          ()=>interval(10000000)

            .pipe(

              mapTo(commit(counterMutationTypes.increment)),

            )

        )

      ).toPromise();



    subject$.next()



  }

};



export default counterActions;

I get the data, but the interval, etc. is completely ignored.
I am using vuex as well.