feat(http2):add sendTimeout and receiveTimeout in Http2Adapter

plugins/http2_adapter/CHANGELOG.md

@@ -2,7 +2,7 @@
 
 ## Unreleased
 
-*None.*
+- Add send timeout and receive timeout
 
 ## 2.3.1+1
 

plugins/http2_adapter/lib/src/http2_adapter.dart

@@ -89,11 +89,21 @@ class Http2Adapter implements HttpClientAdapter {
     }
 
     if (hasRequestData) {
-      await requestStream!.listen((data) {
+      final requestStreamFuture = requestStream!.listen((data) {
         stream.outgoingMessages.add(DataStreamMessage(data));
       }).asFuture();
+      final sendTimeout = options.sendTimeout;
+      if (sendTimeout != null) {
+        await requestStreamFuture.timeout(sendTimeout, onTimeout: () {
+          throw DioException.sendTimeout(
+            timeout: sendTimeout,
+            requestOptions: options,
+          );
+        });
+      } else {
+        await requestStreamFuture;
+      }
     }
-
     await stream.outgoingMessages.close();
 
     final sc = StreamController<Uint8List>();
@@ -145,7 +155,21 @@ class Http2Adapter implements HttpClientAdapter {
       cancelOnError: true,
     );
 
-    await completer.future;
+    final receiveTimeout = options.receiveTimeout;
+    if (receiveTimeout != null) {
+      await completer.future.timeout(
+        receiveTimeout,
+        onTimeout: () {
+          subscription.cancel().whenComplete(() => sc.close());
+          throw DioException.receiveTimeout(
+            timeout: receiveTimeout,
+            requestOptions: options,
+          );
+        },
+      );
+    } else {
+      await completer.future;
+    }
 
     // Handle redirection
     if (needRedirect) {

plugins/http2_adapter/test/http2_test.dart

@@ -1,3 +1,6 @@
+import 'dart:convert';
+import 'dart:io';
+
 import 'package:dio/dio.dart';
 import 'package:dio_http2_adapter/dio_http2_adapter.dart';
 import 'package:test/test.dart';
@@ -76,4 +79,40 @@ void main() {
     final res = await dio.post('post', data: 'TEST');
     expect(res.data.toString(), contains('TEST'));
   });
+
+
+  test('catch DioException when receiveTimeout', () {
+    final dio = Dio()
+      ..options.baseUrl = 'https://httpbun.com/'
+      ..httpClientAdapter = Http2Adapter(
+        ConnectionManager(
+          idleTimeout: Duration(milliseconds: 10),
+        ),
+      );
+    dio.options.receiveTimeout = Duration(seconds: 5);
+
+    expectLater(
+      dio.get('/drip?delay=10&numbytes=1'),
+      allOf([
+        throwsA(isA<DioException>()),
+        throwsA(predicate(
+            (DioException e) => e.type == DioExceptionType.receiveTimeout)),
+        throwsA(predicate(
+            (DioException e) => e.message!.contains('0:00:05.000000'))),
+      ]),
+    );
+  }, testOn: 'vm');
+
+  test('no DioException when receiveTimeout > request duration', () async {
+    final dio = Dio()
+      ..options.baseUrl = 'https://httpbun.com/'
+      ..httpClientAdapter = Http2Adapter(
+        ConnectionManager(
+          idleTimeout: Duration(milliseconds: 10),
+        ),
+      );
+    dio.options.receiveTimeout = Duration(seconds: 5);
+
+    await dio.get('/drip?delay=1&numbytes=1');
+  });
 }