不明白为什么我的 withLatestFrom 运算符被触发

Question

我慢慢开始掌握 rxjs，但偶尔会遇到一些让我困惑的事情。

在这种情况下，它与 withLatestFrom 运算符有关。下面的 rxjs 语句位于我的 angular 组件的 OnInit 方法中。当屏幕加载时，我看到 getApiData() 方法中的 api 调用执行了两次，同时我确定 userEventSubject$ 从未被触发（这就是为什么我有第一个点击运算符）。

我希望发生的是 getApiData() 方法仅在调用 userEventSubject$.next() 时被调用，而不会在屏幕加载时被调用...

this.userEventSubject$
    .pipe(
        tap(creditNote => console.log('tapped!')),
        takeUntil(this.ngUnsubscribe$),
        filter(userEventData => this.checkValidity(userEventData)),
        withLatestFrom(this.apiService.getApiData()),
        mergeMap(([userEventData, apiData]) => {
            let modalRef = this.modalService.show(ModalDialogComponent, {
                initialState: { apiData }
            });
            let instance = <ModalDialogComponent>modalRef.content;

            return instance.save.pipe(
                mergeMap((info) =>
                    this.apiService.saveSomeData(userEventData, info).pipe(
                        catchError((error, caught) => {
                            instance.error = error;
                            return empty();
                        })
                    )
                ),
                tap(response => modalRef.hide())
            );
        })
    )
    .subscribe((response) => {
        this.handleResponse(response);
    });

固定版本：

this.userEventSubject$
    .pipe(
        tap(creditNote => console.log('tapped!')),
        takeUntil(this.ngUnsubscribe$),
        filter(userEventData => this.checkValidity(userEventData)),
        mergeMap(userEventData =>
            this.apiService.getApiData().pipe(
                map(data => {
                    return { userEventData, data };
                })
            )
        ),
        mergeMap(values => {
            let modalRef = this.modalService.show(ModalDialogComponent, {
                initialState: { data: values.apiData }
            });
            let instance = <ModalDialogComponent>modalRef.content;

            return instance.save.pipe(
                mergeMap((info) =>
                    this.apiService.saveSomeData(userEventData, info).pipe(
                        catchError((error, caught) => {
                            instance.error = error;
                            return empty();
                        })
                    )
                ),
                tap(response => modalRef.hide())
            );
        })
    )
    .subscribe((response) => {
        this.handleResponse(response);
    });

Answer 1

在构建管道时，this.apiService.getApiData() 不在箭头函数中，但会立即执行。调用作为参数传递并不重要。表达式像任何其他 JS 调用一样执行（尝试将 console.log 放在同一个地方）。

你可以做 .concatMap(userData => this.apiService.getApiData().map(apidata => {userData, apiData}))（或 switchMap），但那总是会调用 API。我不知道什么最适合您的需求。

不明白为什么我的 withLatestFrom 运算符被触发

Dont understand why my withLatestFrom operator is being triggered

rxjs5

angular