javascript - Firebase 管理 SDK : How to use listUsers() function as Observable combining recursive calls?

Question

如何使用 Firebase 管理 SDK listUsers()充当 RXJS 可观察者的函数？

我可以在 listUsers 上使用 from RXJS 函数返回可观察值，但挑战是 listUsers 批量返回用户。如何检索并合并这批用户？

Answer 1

Firebase 管理 SDK 函数 listUsers可以用返回 Observable 的函数包装。

然后可以使用 flatMap 和 forkJoin 将递归函数调用合并到一个用户数组中。

import { forkJoin, from, of } from 'rxjs';
import { flatMap, map } from 'rxjs/operators';


function myListUsers(maxResults = 1000, pageToken = null) {
  return from(admin.auth().listUsers(1000, pageToken));
}


function listAllUsers(nextPageToken) {
  myListUsers(1000, nextPageToken).pipe(
    flatMap(listUsersResult => forkJoin([
      of(listUsersResult.users),
      listUsersResult.pageToken ? listAllUsers(listUsersResult.pageToken) : of(null)
    ])),
    map( ([userList1, userList2]) => [...userList1, ...userList2])
  )
}


listAllUsers().subscribe(
  allUsers => console.log(allUsers);
)

请注意，最后一个数组条目将为null。