Сброс Angular RX JS Таймер в состоянии - PullRequest
Новая
       5

Сброс Angular RX JS Таймер в состоянии

0 голосов
/ 28 февраля 2020

У меня есть следующий код 

    public timePast:Observable<number>;
    private readonly _stop = new Subject<void>();
    private readonly _start = new Subject<void>();

    this.timePast = timer(1000, 1000).pipe(
            takeUntil(this._stop),
            repeatWhen(() => this._start)
        );

    this.timePast.subscribe(val =>
          {

            console.log(val);
              if(val>=sometime)
              {
                //reset timer
              }

          } );

start(): void {
    this._start.next();
  }
  stop(): void {
    this._stop.next();
  }

Как мне сбросить таймер?

1 Ответ

0 голосов
/ 28 февраля 2020

Вы можете инвертировать часть логи c для начала: 

public timePast: Observable<number> = this._start.pipe(
  switchMap(() => timer(1000, 1000).pipe(takeUntil(this._stop)))
);
...