private _errorDisconnect()

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

• 15 lines of code
• 4 McCabe index (conditional complexity)

  private _errorDisconnect(msg: string) {
    logger(`Disconnect error: ${msg}`);
    this.subscriptionObserverMap.forEach(({ observer }) => {
      if (observer && !observer.closed) {
        observer.error({
          errors: [{ ...new GraphQLError(msg) }],
        });
      }
    });
    this.subscriptionObserverMap.clear();
    if (this.awsRealTimeSocket) {
      this.awsRealTimeSocket.close();
    }

    this.socketStatus = SOCKET_STATUS.CLOSED;
  }