onError method

@override Future<void> onError(DioError err, ErrorInterceptorHandler handler)

The callback will be executed on error.

If you want to continue the error , call handler.next.

If you want to complete the response with some custom data directly, you can resolve a Response object with handler.resolve and other error interceptor(s) will be skipped.

If you want to complete the response with an error message directly, you can reject a DioError object with handler.reject, and other error interceptor(s) will be skipped.

Implementation

@override
Future<void> onError(DioError err, ErrorInterceptorHandler handler) async {
  //(在收到完整标头之前连接已关闭) (握手期间连接终止) (超时)
  if (err.type == DioErrorType.cancel ||
      !err.message.contains('Connection closed before full header was received') &&
          !err.message.contains('Connection terminated during handshake') &&
          !err.message.contains('timed out')) {
    if (hasMore) {
      return handler.next(err);
    } else {
      return handler.reject(err);
    }
  }
  //超过最大重试次数
  if (++_retryCount > _maxRetryCount) {
    _retryCount = 0;
    return handler.reject(err);
  }

  final options = err.requestOptions;

  print('[${options.uri.host}:${options.uri.path}] 重试:$_retryCount次');

  await httpClient
      .request(
        options.path,
        options: Options(method: options.method, headers: options.headers, contentType: options.contentType),
        data: options.data,
        queryParameters: options.queryParameters,
      )
      .then((response) => handler.resolve(response))
      .catchError((e) => handler.reject(err))
      .whenComplete(() => _retryCount = 0);
}