Add timeout parameter to requestToRust function.

cunarist · Nov 2, 2023 · 8c93865 · 8c93865
1 parent aaf3879
commit 8c93865
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/flutter_ffi_plugin/lib/rinf.dart b/flutter_ffi_plugin/lib/rinf.dart
@@ -64,15 +64,18 @@ class Rinf {
 /// this function will return a failed `RustResponse` object.
 /// You can see the usage example at
 /// https://pub.dev/packages/rinf/example.
-Future<RustResponse> requestToRust(RustRequest rustRequest) async {
+Future<RustResponse> requestToRust(
+  RustRequest rustRequest, {
+  Duration timeout = const Duration(seconds: 60),
+}) async {
   final id = _requestIdGenerator.generateId();
   final requestUnique = RustRequestUnique(id: id, request: rustRequest);
   api.requestToRust(requestUnique: requestUnique);
   final future = _responseBroadcaster.stream.firstWhere((responseUnique) {
     return responseUnique.id == id;
   });
   final responseUnique = await future.timeout(
-    const Duration(seconds: 60),
+    timeout,
     onTimeout: () {
       return RustResponseUnique(
         id: id,