RxJS 多个条件调用

Question

我对 RxJS 中的条件调用有疑问。 场景是我在 forkjoin 中有多个 HTTP 调用。但是在调用内部可能存在依赖关系，例如我从第一次调用中得到一个布尔值，如果这是真的，则应该触发第二次调用。 这是我现在的代码：

 service.method(parameters).pipe(
  tap((data: boolean) => {
    foo.bar= data;
  }),
  concatMap(() =>
    service
      .method(parameters)
      .pipe(
        tap((data: KeyValue<number, string>[]) => {
          if (true) {
            foo.foo = data;
          }
        })
      )
  )
)

我遇到的问题是该方法现在总是被调用。我的目标是只在参数为真时调用该方法，以减少调用量。我希望有人可以帮助我。

Answer 1

你可以试试这样的

service.method(parameters).pipe(
  tap((data: boolean) => {
    foo.bar= data;
  }),
  concatMap((data) => data ? // you pass data as parameter and check if true
    service  // if data is true you return the Observable returned by the service method
      .method(parameters)
      .pipe(
        tap((data: KeyValue<number, string>[]) => {
          if (true) {
            foo.foo = data;
          }
        })
      ) :
    of(false) // if data is false you return an Observable containing what you decide it to contain, in this case 'false' but it could be everything
  )
)

这个想法是你第一次调用service.method，将这个调用的结果传递给concatMap，然后你根据传递给concatMap的参数决定是否再次调用service.method和返回它返回的 Observable 或返回您在 concatMap 中创建的 Observable，包装您想要的任何值。