Angular：RxStomp 监视、配置、激活方法

Question

在 Stomp 中，我们使用了这些方法：

initUserEvents() {

this.stompService.startConnect().then(() => {
      this.stompService.done('init');

this.stompService.subsribe('/channel/login', res => {
      if (res.username !== this.username) {

        this.newConnectedAccounts.push(res.username);

现在我正在使用 RxStomp，但我无法找到使用这些“替换”方法的正确方法：

initUserEvents() {

this.stompService.configure();
    this.stompService.activate(){

    this.stompService.watch('/channel/login', res => {
      if (res.username !== this.username) {
        this.newConnectedAccounts.push(res.username);

我得到的错误是： TS2345：'(res: any) => void' 类型的参数不能分配给'StompHeaders' 类型的参数。 '(res: any) => void' 类型中缺少索引签名。

Answer 1

查看 RxStomp 文档。它说：

主要区别在于它将操作公开为 RxJS Observables。例如，当订阅 STOMP 端点时，它会返回一个 Observable，它将流式传输所有接收到的消息。

除了 beforeConnect，与 @stomp/stompjs Client 中所有回调相关的功能都公开为 Observables/Subjects/BehaviorSubjects。

换句话说，您不会将回调传递给watch 方法。它返回一个Observable，您可以使用它来获取消息。

RxStomp API 希望您将标头传递给 watch 方法，而不是回调。这就是为什么它专门告诉你：

TS2345: Argument of type '(res: any) => void' is not assignable to parameter of type 'StompHeaders'.