RxJS管道Finalize运算符未被调用

Question

import {
    Observable,
    BehaviorSubject
} from 'rxjs';
import {
    finalize,
    share
} from 'rxjs/operators'

export class someComponent() {

    public count$ = new BehaviorSubject < any > (0);

    public constructor() {
        this.shareResponse()
            .pipe(
                finalize(() => {
                    console.log('finalize called');
                }))
            .subscribe((event: any) => {
                // Do something
            });
    }
    public shareResponse(): Observable < any > {
        return this.count$.pipe(share());
    }
    public countChanged(event) {
        this.count$.next(event);
    }
}

HTML：

    <some-tag(countChanged) = (countChanged($event)) > < /some-tag>

Answer 1

BehaviorSubject不会完成，除非您通过致电自己完成this.count$.complete()。这就是为什么finalize（）不会发生的原因，因为它正在等待Observable完成。

看一下StackBlitz上的代码示例，请参见link。