如何保持RXJ干燥

使用pipeable操作符要记住的一点是,它们只是获取一个observate并返回一个observate的函数,因此您可以轻松地创建可重用的操作符组合,如下所示:

function getReusedOperators(factor) {
  return source => source.pipe(
    tap(value => console.log(value)),
    map(value => value * factor),
  );
}

对于可重用组合未参数化的情况,可以使用 pipe 功能。看我的 Combining Operators 文章中有一些例子。

如果您想要可以添加到管道中的可重用的内容,可以编写返回OperatorFunction(在rxjs中定义)的方法。管道运算符将一个或多个运算符函数作为参数。

下面是我在应用程序中使用的其中一个示例:

  /*
   * Returns an "OperatorFunction", suitable for passing to rx.pipe(),
   * that maps a Role[] to a sorted FormRole[] (sorted by role name)
   */
  public rolesToSortedFormRolesMapper(): OperatorFunction<Role[], FormRole[]> {
    return map((roles: Role[]) => roles.map((role) =>
        new FormRole(role.role, role.name, false)
      ).sort((lhs, rhs) => (lhs.name.localeCompare(rhs.name)))
    );
  }

例如,它可以与,

someObservable.pipe(rolesToSortedFormRolesMapper())