代码之家 › 专栏 › 技术社区 › SimplGy

如果RxJs主题的refCount降为零,请执行某些操作

observable rxjs

SimplGy · 技术社区 · 7 年前

我正在研究一个管理订阅的服务层。

我向消费者提供主题支持的观察结果如下:

const subject = new Subject();
_trackedSubjects.push(subject);
return subject.asObservable();

我想监控一下 subject.observers 如果它降回0,在我的库中做一些清理。

我已经查看了refCount,但这只在observeable上可用。

我很想找到这样的东西:

subject.onObserverCountChange((cur, prev) =>
  if(cur === 0 && prev !== 0) { cleanUp(subject) }
)

有没有办法像这样对一个主题进行自动清理?

1 回复 | 直到 7 年前

Oles Savluk 7 年前

而不是使用 Subject -您可能应该在创建observable时描述设置/清理逻辑。参见示例:

const { Observable } = rxjs; // = require("rxjs")
const { share } = rxjs.operators; // = require("rxjs/operators")

const eventSource$ = Observable.create(o => {
  console.log('setup');
  let i = 0
  const interval = setInterval(
    () => o.next(i++),
    1000
  );

  return () => {
    console.log('cleanup');
    clearInterval(interval);
  }
});
const events$ = eventSource$.pipe(share());

const first = events$.subscribe(e => console.log('first: ', e));
const second = events$.subscribe(e => console.log('second: ', e));

setTimeout(() => first.unsubscribe(), 3000);
setTimeout(() => second.unsubscribe(), 5000);

<script src="https://unpkg.com/rxjs@6.2.2/bundles/rxjs.umd.min.js"></script>

推荐文章

Anjil Dhamala · 在收到特定http状态时重试http调用

7 年前

simonberry · 取消RXJS FlatMap链上的订阅

7 年前

user9487981 · 可以激活防护装置并使用角度为5的可见光

7 年前

makat · 角度5 HTTP请求间隔使用可观察值,而值可能会更改

7 年前

Gissipi_453 · 在RxJava 2中的可观察对象中发出字符串数组时出现“不兼容类型”错误

7 年前

Jake Shakesworth · 如何将一个可观察对象映射到另一个可观察对象

7 年前

Nomura Nori · 许诺仅当使用了4个以上的承诺时,才获得“Access Control Allow Origin”

7 年前

MindlessRouse · 路由解析程序在没有订阅的情况下不触发可观察

7 年前

DevMike · 在角度服务中,如果在可观测范围内使用贴图功能,那么假设贴图功能保证同步是否正确?

7 年前

Arun Prasad E S · 角度5,离子3-【ts】类型“void”不可分配给类型“Observable<Post[]>”

7 年前