private async _verifySubscriptionAlreadyStarted()

in packages/aws-appsync-subscription-link/src/realtime-subscription-handshake-link.ts [152:175]

23 lines of code
2 McCabe index (conditional complexity)


  private async _verifySubscriptionAlreadyStarted(subscriptionId) {
    const { subscriptionState } = this.subscriptionObserverMap.get(
      subscriptionId
    );
    // This in case unsubscribe is invoked before sending start subscription message
    if (subscriptionState === SUBSCRIPTION_STATUS.PENDING) {
      return new Promise((res, rej) => {
        const {
          observer,
          subscriptionState,
          variables,
          query
        } = this.subscriptionObserverMap.get(subscriptionId);
        this.subscriptionObserverMap.set(subscriptionId, {
          observer,
          subscriptionState,
          variables,
          query,
          subscriptionReadyCallback: res,
          subscriptionFailedCallback: rej
        });
      });
    }
  }