private _timeoutStartSubscriptionAck()

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

• 26 lines of code
• 5 McCabe index (conditional complexity)

  private _timeoutStartSubscriptionAck(subscriptionId) {
    const { observer, query, variables } =
      this.subscriptionObserverMap.get(subscriptionId) || {};

    if (!observer) {
      return;
    }

    this.subscriptionObserverMap.set(subscriptionId, {
      observer,
      query,
      variables,
      subscriptionState: SUBSCRIPTION_STATUS.FAILED
    });

    if (observer && !observer.closed) {
      observer.error({
        errors: [
          {
            ...new GraphQLError(
              `Subscription timeout ${JSON.stringify({ query, variables })}`
            )
          }
        ]
      });
      // Cleanup will be automatically executed
      observer.complete();
    }
    logger("timeoutStartSubscription", JSON.stringify({ query, variables }));
  }