reconnect method

void reconnect({ bool reset = false, })

Reconnects websocket

Implementation

void reconnect({bool reset = false}) {
  if (reset) {
    _reconnectTimer?.cancel();
    _reconnectTimer = null;
    _state.resetReconnectTask();
  }

  if (_reconnectTimer != null) return;

  final task = _state.reconnectTask;
  if (task == null) throw MisConfigurationError();
  if (task.exceedRetryCount && task.hasRetriedLastChance) {
    task.increaseRetryCount();
    _state.reconnecting = false;
    _eventManager.notifyReconnectionFailed();
    return;
  }

  final backoffPeriod = task.backOffPeriod;
  task.increaseRetryCount();
  _state.reconnecting = true;

  _reconnectTimer = Timer(Duration(seconds: backoffPeriod), () async {
    logger.i('try to reconnect');
    try {
      await connect(
        reconnect: true,
        userId: _state.userId ?? '',
        accessToken: _sessionManager.accessToken,
      );
    } catch (e) {
      _eventManager.notifyReconnectionCanceled();
      _state.reconnecting = false;
      logger.e('reconnecting error: $e');
    }
    logger.i('reconnect succeeded');
  });
}