breakPointUpload method

Implementation

void breakPointUpload({
  required String filePath,
  adapter.ProgressCallback? onSendProgress,
  Success? success,
  Failure? failure,
  Completed? completed,
  Function()? cancelCallback,
  int? start,
}) async {
  if (!(await _checkNetWork())) {
    return;
  }

  final url = _buildFinalUrl();

  var progress = start ?? 0;
  int fileSize = 0;
  File file = File(filePath);

  if (file.existsSync()) {
    fileSize = file.lengthSync();
  }

  var data = file.openRead(progress, fileSize);

  try {
    // 添加 Content-Range 头部
    final headers = _buildHeaders();
    headers['Content-Range'] = 'bytes $progress-${fileSize - 1}/$fileSize';

    // 构建 AdapterRequest，外部通常需要将responseType设置为 stream 响应类型
    final adapterRequest = adapter_models.AdapterRequest(
      baseUrl: _rxNet.baseUrl,
      path: url,
      method: _HttpMethod,
      queryParams: _queryParams,
      headers: headers,
      rawBody: data,
      contentType: _contentType,
      responseType: _convertResponseType(),
      sendTimeout: _sendTimeout,
      receiveTimeout: _receiveTimeout,
      cancelToken: _cancelToken, // Use the actual cancel token
    );

    // 使用适配器发送请求
    final adapter = _rxNet.getAdapter();
    if (adapter == null) {
      throw NetworkException("NetworkAdapter is not initialized", null);
    }

    final response = await adapter.request(adapterRequest);
    onResponse?.call(response);

    // 处理流式响应
    if (response.data is Stream<List<int>>) {
      Stream<Uint8List> stream = (response.data as Stream<List<int>>).map((d) => Uint8List.fromList(d));

      final subscription = stream.listen((d) {
        progress = progress + d.length;
        onSendProgress?.call(progress, fileSize);
      }, onDone: () async {
        success?.call(file, SourcesType.net);
      }, onError: (e) async {
        failure?.call(e);
      }, cancelOnError: true);
    } else {
      // 如果不是流式响应，检查是否已完成
      if (progress <= fileSize) {
        onSendProgress?.call(progress, fileSize);
        success?.call(file, SourcesType.net);
      }
    }
  } on AdapterException catch (error) {
    if (error.type == AdapterExceptionType.cancel) {
      cancelCallback?.call();
    } else {
      failure?.call(error);
    }
  } catch (e) {
    failure?.call(e);
  }

  completed?.call();
}