代码之家 › 专栏 › 技术社区 › S Panfilov

RxJS takeUntil不退订

reactive-programming rxjs javascript

S Panfilov · 技术社区 · 7 年前

我想用“takeUntil”运算符以声明式方式取消订阅。但这基本上不起作用。我可以看到控制台输出。

const unsubscribe = new Subject();

function printFoo() {
  of('foo')
    .pipe(takeUntil(unsubscribe))
    .subscribe(console.log) // Why I can see 'foo' in the  console?
}

function onDestroy() {
  unsubscribe.next();
  unsubscribe.complete();
}

onDestroy()
setTimeout(() => printFoo(), 200)

斯塔克闪电战:

https://stackblitz.com/edit/rxjs-svfkxg?file=index.ts

附笔。 我甚至还以为 unsubscribe.next() 取消订阅就足够了,但即使有 unsubscribe.complete() 它不起作用。

1 回复 | 直到 7 年前

martin 7 年前

你在打电话 onDestroy() 在链条之前 takeUntil 甚至被创建。

当你最终打电话时 printFoo() 之前排放至 unsubscribe 不会再次发射,主题 退订 反正已经完成了所以 takeUntil公司 在这种情况下,将永远无法完成链。

Roberto ZvjerkoviÄ sabithpocker 7 年前

因为主体在 printFoo 订阅

订阅后,不再有主题发射。

您可以改用BehaviorSubject,因为它保存发出的值(最后一个值) 排放值):

const unsubscribe = new BehaviorSubject(false);

function printFoo() {
  of('foo')
    .pipe(takeUntil(unsubscribe.pipe(filter(value => !!value)))) // Don't unsub if it's false emitted
    .subscribe(console.log)
}

function onDestroy() {
  unsubscribe2.next(true); // Emit true to cancel subscription
}

推荐文章

Ole · 在使用新的Angular Resource API时取消搜索术语?

1 年前

koque · 为什么我的RxJs主题没有按预期工作?

1 年前

Raphaël VO · 不使用Observable的初始值

1 年前

xarielah · 从app.config.ts调用时,BehaviorSubject不会更新

1 年前

Lenni · 返回信号并在Angular中订阅它

1 年前

dman · 在Angular单元测试中似乎无法模拟行为主体

1 年前

Nevyan Dimitrov Neykov · 效果内部的角度信号()

1 年前

Ð¤ÐµÐ´Ñ Ð Ð°Ð²ÑÐµÐµÐ² · 如何在react-js中使用Date()在后台增加变量?

1 年前

Ryley38 · 如何跳过流的第一个值,除非它是RxJS的复制粘贴?

2 年前

techwestcoastsfosea · Angular 18-RxJS:Subscribe已弃用[重复]

2 年前