Rxjs 等待运算符

Question

我正在与 rxjs 运算符作斗争。其实我有这个例子。

constructor() {}

  ngOnInit(): void {
    //this.demo();
  }

  demo = () => {
    const obs = interval(15000);

    obs.subscribe(this.handleMessage.bind(this));
  };
  handleMessage() {
    alert('Hello');
  }

我想在用户没有点击 OK with alert 时忽略所有 obs 事件。我想添加一个新的 observable 以忽略 obs 事件，但它不起作用

import { Component, OnInit } from '@angular/core';
import { BehaviorSubject, interval, Observable, Subscription } from 'rxjs';
import { filter, first, switchMap, take } from 'rxjs/operators';

@Component({
  selector: 'my-app',
  templateUrl: './app.component.html',
  styleUrls: ['./app.component.css'],
})
export class AppComponent implements OnInit {
  name = 'Angular';
  instance = new BehaviorSubject({ status: true });
  instanceObs$ = this.instance.asObservable();
  subscription = new Subscription();
  constructor() {}

  ngOnInit(): void {
    this.demo();
  }

  demo = () => {
    const obs$ = interval(5000);
    this.subscription = obs$
      .pipe(waitFor(this.instanceObs$.pipe(filter((r) => r.status))), take(1))
      .subscribe(this.handleMessage.bind(this));
  };
  handleMessage() {
    this.instance.next({ status: false });
    alert('Hello');
    this.instance.next({ status: true });
  }
}
export function waitFor<T>(signal: Observable<any>) {
  return (source: Observable<T>) =>
    signal.pipe(
      first(),
      switchMap((_) => source)
    );
}

Alert 是一个示例，我使用 confirm devextrem 来处理带有异步运算符的真实场景

async handleUpdateFromAnotherTab(message: IRocketBroadcastMessage) {
    this.instance.next({ status: false });
    let result = await confirm(
      'Data has been updated from another tab. Would you like to reload it?',
      'Warning'
    );
    if (result) {
      window.location.reload();
    }
    this.instance.next({ status: true });
  }
}

StackBlitz

Answer 1

试试这个。

@Component({
  selector: 'my-app',
  templateUrl: './app.component.html',
  styleUrls: ['./app.component.css'],
})
export class AppComponent implements OnInit {
  name = 'Angular';
  alerted = false;
  subscription = new Subscription();

  constructor() {}

  ngOnInit(): void {
    this.demo();
  }

  demo = () => {
    const obs$ = interval(5000);
    this.subscription = obs$
      .pipe(filter( () => this.alerted === false))
      .subscribe(this.handleMessage());
  };

  handleMessage = () => {
    this.alerted = true;
    alert('Hello');
    this.alerted = false;
  }

}

Rxjs 等待运算符

Rxjs Wait Operator

rxjs

angular

rxjs6