对可观察的角度订阅 - 仅在请求后才需要价值

Question

我有一个看起来像这样的服务：

export class WebViewService {

  private webViewMessage = new ReplaySubject<any>(1);
  public webViewMessage$ = this.webViewMessage.asObservable();

  public isWebView: boolean = false;
  constructor() {
    this.isWebView = false;

    if (window?.chrome?.webview)
    {
      this.isWebView = true;
    }
   
    window?.chrome?.webview?.addEventListener('message', (event: { data: any; }) => {
      this.webViewMessage.next(event.data);
    });
  }

  public postMessage(message: any) {
    window?.chrome?.webview?.postMessage(message);
  }
}

而且我有一个看起来像这样的组件：

export class BrowserComponent implements OnInit {

  constructor(private webViewService: WebViewService) { }

  subscription!: Subscription;

  ngOnInit(): void {
    this.subscription = this.webViewService.webViewMessage$.subscribe(o => {
      alert(o);
    });
  }

  ngOnDestroy() {
    this.subscription.unsubscribe();
  }

  onClick() {
    this.webViewService.postMessage("showDialog");
  }
}

当调用onclick（）方法时，通过WebViewService发布了一条消息，该消息又在父窗口（窗口表单）中显示出显示一个文件对话框，然后我想知道响应是什么，这将在WebViewMessage $中。我现在在订阅中显示一个警报（），但是将来会有所不同。

问题：当我离开浏览组件然后再次输入时，该警报会弹出最后一个WebViewMessage $，这是我期望的，但不是我想要的。

我可以将OnClick（）代码更改为类似的内容：

  onClick() {
    this.webViewService.postMessage("showDialog");
    this.subscription = this.webViewService.webViewMessage$.subscribe(o => {
      alert(o);
      this.subscription.unsubscribe();
    });
  }

但是，一旦我再次单击OnClick（）按钮，这将弹出最后一条消息 - 我知道为什么会发生这种情况，但是我无法“等待” postmessage（）方法接收响应。但同样，我只希望在此之后收到的消息。WebViewService.PostMessage（）已被调用。我该怎么做？

Answer 1

制作行为是为了保留发出的最后一个值。这就是为什么创建它时，必须提供默认值。

replayubject是为了保留发出的给定数量的值。创建它时，您必须指定要保留多少值。

而是使用主题，观察者只有在发送值时才会触发，并且不会保留发出的最后一个值。

private webViewMessage = new Subject<any>();