Rxjs：根据可观察值，管道使用mergeMap或switchMap

Question

我们有一个执行http请求的请求服务。所有请求都实现IRequest接口，该接口包含http方法和一个执行函数，该函数依次返回另一个可观察的对象。

RequestService有一个重载，它接受一个源可观察对象，还有一个requestfactory，它根据源可观察对象的值返回一个IRequest实例。

export interface IRequest<TResponse> {
    __method: string;
    execute(): Observable<TResponse>;
}

class RequestService<TSource, TResponse> {
    public execute(source: Observable<TSource>, requestFactory: (input: TSource) => IRequest<TResponse>): Observable<TResponse> {
        return source.pipe(
            map(x => requestFactory(x)),
            switchMap(x => x.execute()),
        );
    }
}

当然，在服务中做了更多的工作（日志记录、默认错误处理，...），但大多数与问题无关。

现在，这一切都像一个符咒，但我们想做的是，使用switchMap获取请求，默认情况下使用“mergeMap”发布、放置和删除请求。

我们似乎无法让这工作。我们需要在工厂创建IRequest实例后访问它，这只有在我们有可观察的源值的情况下才有可能。但是，在操作员中，我们不能再控制开关地图或合并地图之间的选择。

我们的下一个选择是创建自己的RequestMapOperator，它将创建MergeMapOperator或SwitchMapOperator的实例，并使用适当的next、complete和error方法。但是，rxjs库不会导出SwitchMapOperator。

因此，在创建我们自己的订阅类之前，我们想知道我们是否遗漏了什么。

TL；博士

我们想要一个操作符，它根据源可观测值，用mergeMap或switchMap展平到一个新的可观测值。

Answer 1

您可以使用RXJS iif函数，该函数将条件函数作为第一个参数，并根据返回的值决定订阅哪个可观察对象。

例如。

class RequestService<TSource, TResponse> {
    public execute(source: Observable<TSource>, requestFactory: (input: TSource) => IRequest<TResponse>): Observable<TResponse> {
        return source.pipe(
            map(x => requestFactory(x)),
            // using mergemap outside because we don't want to cancel inner 
            // observable
            margeMap((x) => 
              iif(() => x.method === "GET", 
               switchMap(x => x.execute()),
               margeMap(x => x.execute())
              )
            )
        );
    }
}

希望有帮助。