用于多个可观察对象的 RXJS 序列

Question

我正试图围绕 RXJS 进行思考，并有一个关于如何使用 observables 而不是 Promise 来处理以下工作流的快速问题。

这是 Angular 2 中的登录工作流程：

• 我在本地存储中查找 JWT。如果 JWT 存在，我会返回令牌。
• 如果不在本地存储中，我会检查平台。如果 Android 我使用谷歌不记名令牌登录到我的服务器，我的服务器会返回一个 JWT（通过 angular HTTP obserable）。
• 如果不在本地存储中并且平台是 Windows 计算机，我会在我的服务器上生成 JWT 并返回（通过 Angular HTTP obserable）
• 对于对服务器的两次调用，我想在将 JWT 信息返回给调用函数之前将令牌缓存在本地存储中。

除了如何使用 RXJS 正确执行此操作之外，我拥有一切，主要是如何将所有这些链接在一起。我可以使用 Observables 快速获取伪代码来了解如何执行此操作吗？我基本上想在应用程序继续之前拦截JWT并存储在本地存储中（调用函数订阅上面的序列）

任何帮助都会很棒！

Answer 1

我更喜欢这个任务的异步函数。

var jwtPromise = null;

function getJwt() {
  return jwtPromise || (jwtPromise = getJwtNotCached());
}

async function getJwtNotCached() {
  const localJwt = getLocalJwt();
  if (localJwt) {
    return localJwt;
  }
  const newJwt = await fetchJwtByPlatform();
  storeLocalJwt(newJwt);
  return newJwt;
}

async function fetchJwtByPlatform() {
  if (platformIsAndroid()) {
    return await fetchJwtOnAndroid();
  }
  return await fetchJwtOnWindows();
}

...

如果一次调用两次，此代码甚至可以确保不会发出多个网络请求。