commit 329f6f47ff800b59b6c4aa4e0245189711fb23fc
author Nate Bosch <nbosch@google.com> Thu Jan 28 12:21:31 2021 -0800
committer Nate Bosch <nbosch@google.com> Thu Jan 28 12:21:31 2021 -0800
tree 2675445c0bad3a48b1c68679a5d593adb873aba6
parent 4f3dd7150086fc76c2d4b420def0ca70fc11bbad

Guard all completions with checks

lib/src/io_client.dart

diff --git a/lib/src/io_client.dart b/lib/src/io_client.dart
index 90809fe..590b831 100644
--- a/lib/src/io_client.dart
+++ b/lib/src/io_client.dart
@@ -39,8 +39,10 @@
     void Function() onTimeout;
     if (contentTimeout != null) {
       onTimeout = () {
-        completer
-            .completeError(TimeoutException('Request aborted', contentTimeout));
+        if (!completer.isCompleted) {
+          completer.completeError(
+              TimeoutException('Request aborted', contentTimeout));
+        }
       };
       timer = Timer(contentTimeout, () {
         onTimeout();
@@ -60,8 +62,10 @@
       if (contentTimeout != null) {
         onTimeout = () {
           ioRequest.abort();
-          completer.completeError(
-              TimeoutException('Request aborted', contentTimeout));
+          if (!completer.isCompleted) {
+            completer.completeError(
+                TimeoutException('Request aborted', contentTimeout));
+          }
         };
       }
 
@@ -91,15 +95,18 @@
         sink.close();
       }));
 
-      completer.complete(IOStreamedResponse(responseStream, response.statusCode,
-          contentLength:
-              response.contentLength == -1 ? null : response.contentLength,
-          request: request,
-          headers: headers,
-          isRedirect: response.isRedirect,
-          persistentConnection: response.persistentConnection,
-          reasonPhrase: response.reasonPhrase,
-          inner: response));
+      if (!completer.isCompleted) {
+        completer.complete(IOStreamedResponse(
+            responseStream, response.statusCode,
+            contentLength:
+                response.contentLength == -1 ? null : response.contentLength,
+            request: request,
+            headers: headers,
+            isRedirect: response.isRedirect,
+            persistentConnection: response.persistentConnection,
+            reasonPhrase: response.reasonPhrase,
+            inner: response));
+      }
     } on HttpException catch (error) {
       if (completer.isCompleted) return;
       completer.completeError(ClientException(error.message, error.uri));