[ApiOptions] Add cancel token to base methods

FieldAssist · Jan 4, 2024 · b80a47b · b80a47b
1 parent fd87957
commit b80a47b
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/lib/src/api_options/api_options.dart b/lib/src/api_options/api_options.dart
@@ -1,10 +1,13 @@
+import 'package:dio/dio.dart';
+
 class ApiOptions {
   ApiOptions({
     this.headers = const {},
     this.receiveTimeout,
     this.sendTimeout,
     this.refreshCache,
     this.expireDuration = const Duration(days: 1),
+    this.cancelToken,
   });
 
   Map<String, dynamic>? headers;
@@ -16,4 +19,6 @@ class ApiOptions {
   bool? refreshCache;
 
   Duration? expireDuration;
+
+  CancelToken? cancelToken;
 }
diff --git a/lib/src/api_service_impl.dart b/lib/src/api_service_impl.dart
@@ -46,6 +46,7 @@ class ApiServiceImpl implements ApiService {
     ApiOptions? options,
   }) async {
     return _dio!.get<T>(checkIfNotEmpty(url) ? '$url' : '$baseUrl$endpoint',
+        cancelToken: options?.cancelToken,
         options: Options(
           headers: _formatHeaders(options),
           receiveTimeout: options?.receiveTimeout,
@@ -62,6 +63,7 @@ class ApiServiceImpl implements ApiService {
   }) async {
     return _dio!.post<T>(url ?? '$baseUrl$endpoint',
         data: body,
+        cancelToken: options?.cancelToken,
         options: Options(
           headers: _formatHeaders(options),
           receiveTimeout: options?.receiveTimeout,
@@ -75,6 +77,7 @@ class ApiServiceImpl implements ApiService {
     ApiOptions? options,
   }) async {
     return _dio!.delete<T>('$baseUrl$endpoint',
+        cancelToken: options?.cancelToken,
         options: Options(
           headers: _formatHeaders(options),
           receiveTimeout: options?.receiveTimeout,
@@ -89,6 +92,7 @@ class ApiServiceImpl implements ApiService {
     ApiOptions? options,
   }) async {
     return _dio!.put<T>('$baseUrl$endpoint',
+        cancelToken: options?.cancelToken,
         data: body,
         options: Options(
           headers: _formatHeaders(options),
@@ -103,6 +107,7 @@ class ApiServiceImpl implements ApiService {
     String? keyName,
     File? file,
     ProgressCallback? onSendProgress,
+    ApiOptions? options,
   }) async {
     endpoint = endpoint != null ? "$baseUrl$endpoint" : getFileUploadUrl();
     keyName = keyName ?? 'asset';
@@ -123,6 +128,7 @@ class ApiServiceImpl implements ApiService {
     });
     return _dioFile!.post<T>(
       endpoint,
+      cancelToken: options?.cancelToken,
       data: formData,
       onSendProgress: onSendProgress,
     );