AsyncPipe在Eventsource关闭后仍显示加载模板。
创始人
2024-09-21 08:30:13
0

一种解决方法是使用RxJS的takeUntil操作符,在EventSource关闭时取消订阅流。以下是一个示例:

import { Injectable } from '@angular/core';
import { Observable, Subject } from 'rxjs';
import { takeUntil } from 'rxjs/operators';

@Injectable()
export class MyService {
  private destroy$: Subject = new Subject();

  constructor() {}

  getData(): Observable {
    return new Observable(observer => {
      const eventSource = new EventSource('http://localhost:8080/api/data');
      eventSource.onmessage = event => {
        observer.next(event.data);
      };
      eventSource.onerror = error => {
        observer.error(error);
      };
      return () => {
        console.log('Closing EventSource...');
        eventSource.close();
      };
    }).pipe(
      takeUntil(this.destroy$)
    );
  }

  ngOnDestroy() {
    this.destroy$.next(true);
    this.destroy$.unsubscribe();
  }
}

在上面的代码中,我们使用了一个Subject来跟踪组件或服务的销毁。我们使用takeUntil操作符来在销毁时取消订阅流。在这个例子中,我们展示了如何使用Observable来订阅EventSource对象,然后在组件或服务的ngOnDestroy方法中调用destroy$的next和unsubscribe方法来销毁这个对象。这样就可以避免Async Pipe在EventSource关闭后仍然显示加载模板的问题。

相关内容

热门资讯

黑科技安装!governoro... 黑科技安装!governorofpoker3有挂(微扑克如何让系统发好牌)真是有挂(有挂秘籍)-哔哩...
黑科技智能ai!wepoke有... 黑科技智能ai!wepoke有app软件(aapoker发牌机制)一贯存在有挂(有挂解惑)-哔哩哔哩...
黑科技美元局!德扑之星系统发牌... 黑科技美元局!德扑之星系统发牌机制(微扑克ai机器人)起初是真的有挂(有挂方法)-哔哩哔哩微扑克ai...
黑科技挂!fishpoker大... 黑科技挂!fishpoker大菠萝外挂(德扑ai智能机器人线上代打)先前是真的有挂(有挂助手)-哔哩...
黑科技脚本!pokerworl... 黑科技脚本!pokerworld软件(德扑ai软件靠谱吗)切实是真的有挂(有挂透视)-哔哩哔哩1、打...
黑科技有挂!aapoker有外... 黑科技有挂!aapoker有外挂(wpk到底有没有外挂)固有真的有挂(真实有挂)-哔哩哔哩,您好,w...
黑科技好友!微扑克如何让系统发... 您好,微扑克如何让系统发好牌这款游戏可以开挂的,确实是有挂的,需要了解加威信【136704302】很...
黑科技ai!德扑之星辅助工具(... 黑科技ai!德扑之星辅助工具(微扑克有挂么)从来是有挂(发现有挂)-哔哩哔哩1、微扑克有挂么ai辅助...
黑科技美元局!轰趴大菠萝十三水... 黑科技美元局!轰趴大菠萝十三水有外挂(德扑ai智能系统)总是是真的有挂(果真有挂)-哔哩哔哩1、德扑...
黑科技脚本!wepoke辅助机... 黑科技脚本!wepoke辅助机器人(德扑ai软件靠谱吗)往昔真的是有挂(揭秘有挂)-哔哩哔哩德扑ai...