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关闭后仍然显示加载模板的问题。

相关内容

热门资讯

透视辅助"德州局hh... 透视辅助"德州局hhpoker"切实真的有辅助技巧(哔哩哔哩)1、许多玩家不知道德州局hhpoker...
透视揭露"hhpok... 透视揭露"hhpoker可以控制吗"本来真的是有辅助教程(哔哩哔哩)1、完成hhpoker可以控制吗...
透视教你"wepok... 透视教你"wepoker怎么提高运气"竟然真的是有辅助app(哔哩哔哩)1、wepoker怎么提高运...
透视解密"德州透视h... 透视解密"德州透视hhpoker"其实真的有辅助挂(哔哩哔哩)德州透视hhpoker能透视中分为三种...
透视推荐"wepok... 透视推荐"wepoker永久免费脚本"真是真的是有辅助技巧(哔哩哔哩)1、wepoker永久免费脚本...
透视详情"wepok... 透视详情"wepoker怎么挂飞机"本来真的是有辅助工具(哔哩哔哩)1、首先打开wepoker怎么挂...
透视推荐"wepok... 透视推荐"wepoker黑侠辅助器"原来真的是有辅助挂(哔哩哔哩)1、玩家可以在wepoker黑侠辅...
透视辅助"约局吧是否... 透视辅助"约局吧是否有挂"确实存在有辅助app(哔哩哔哩)1、约局吧是否有挂破解器简单,约局吧是否有...
透视分享"德州局怎么... 透视分享"德州局怎么透视"一直真的是有辅助挂(哔哩哔哩)1.德州局怎么透视 选牌创建新账号,点击进入...
透视总结"wpk模拟... 透视总结"wpk模拟器是什么"本来是真的辅助神器(哔哩哔哩)wpk模拟器是什么能透视中分为三种模型:...