防止 rxjs 主题完成

Question

在下面的示例代码中，testSubj 通过take 运算符订阅了两次sourceSubj 其中之一。似乎发生的情况是，当 take Observable 完成时，它会导致 testSubj 完成，即使它仍然有一个有效的订阅。

我的问题是，为什么会出现这种行为？有没有办法阻止主题完成？

rxjs 6.4

import { Subject } from 'rxjs';
import { take } from 'rxjs/operators';

const sourceSubj = new Subject<string>();

const testSubj = new Subject<string>();
testSubj.subscribe({
  next: s => console.log(`next: ${s}`), 
  complete: () => console.log(`completed`)
});

sourceSubj.pipe( take(1) ).subscribe(testSubj);
sourceSubj.subscribe(testSubj);
sourceSubj.next('1');

Answer 1

它完成是因为它的 complete 方法在 take 运算符返回的 observable 完成时被调用。

主题是观察者，并响应next、error 和complete 通知。如果您只想订阅next 和error 通知，请仅将其转发给主题：

sourceSubj.pipe(take(1)).subscribe({
  next: value => testSubj.next(value),
  error: error => testSubj.error(error) 
});

Answer 2

尝试将Subject 视为具有状态的对象，一旦完成，它就会停止执行其任务

你应该只使用merge https://codesandbox.io/embed/rxjs-subject-cb86j?fontsize=14&hidenavigation=1&theme=dark

import { merge, Subject } from 'rxjs';
import { take } from 'rxjs/operators';

const sourceSubj = new Subject<string>();

const first = sourceSubj.pipe(take(1));
const subscription = merge(sourceSubj, first).subscribe({
  next: s => console.log(`next: ${s}`), 
  complete: () => console.log(`completed`)
});

sourceSubj.next('1');