不使用成功/失败块的角度嵌套 HTTP 调用

Question

这里 createSampleUser 服务可以从服务器给出成功/错误响应。但我想在 createSampleUser 服务调用之后调用 getUsers 服务。 因为我接下来不在这里使用，错误块......那我为什么要写这 2/3 行代码。 有没有办法在不检查第一次服务调用的成功/错误响应的情况下调用嵌套调用？

getUsers() {
        this.userService.createSampleUser({ fName: 'surendra', lName: 'tarai' })
            .subscribe(
                next => { },
                error => { },
                () => {
                    this.users$ = this.userService.getUsers('BLR');
                }
            );
    }

Answer 1

您可以为此使用switchMap。

import { switchMap } from 'rxjs/operators';
....
getUsers() {
        this.userService.createSampleUser({ fName: 'surendra', lName: 'tarai' })
            .pipe(switchMap(sampleUser => this.userService.getUsers('BLR')))
            // .subscribe(); You have to subscribe to this stream. If this is a service,
            // I would subscribe from the component. If it's a component, 
           //then keep the subscribe and do something with it
    }

Answer 2

只需使用switchMap:

this.userService.createSampleUser({ fName: 'surendra', lName: 'tarai' })
    .pipe(switchMap(() => this.userService.getUsers('BLR')))
    .subscribe(users => ...)

编辑：

const createUser$ = this.userService.createSampleUser({ fName: 'surendra', lName: 'tarai' });
const handlingError = catchError(err => of(err); // guarantee flow continuity
const getUsers$ = this.userService.getUsers('BLR');
const stream$ = createUser$.pipe(handlingError, concatMap(() => getUsers$);

stream$.subscribe();

请注意，stream$ 订阅将仅发出 getUsers$ 的结果，如果您想获取所有“子流”的事件，请使用concat 而不是concatMap。