diff --git a/lib/src/utils/http_timeout.dart b/lib/src/utils/http_timeout.dart index 108fceac..12025e24 100644 --- a/lib/src/utils/http_timeout.dart +++ b/lib/src/utils/http_timeout.dart @@ -1,4 +1,3 @@ -// @dart=2.9 /* * Famedly Matrix SDK * Copyright (C) 2021 Famedly GmbH @@ -27,7 +26,7 @@ import '../../matrix.dart'; /// In contrast, streamTotalTimeout fails if the stream isn't completed /// until timeoutFuture. Stream streamTotalTimeout( - Stream stream, Future timeoutFuture) async* { + Stream stream, Future timeoutFuture) async* { final si = StreamIterator(stream); while (await Future.any([si.moveNext(), timeoutFuture])) { yield si.current; @@ -58,7 +57,7 @@ abstract class TimeoutHttpClient extends http.BaseClient { @override Future send(http.BaseRequest request) async { - final timeoutFuture = Completer().future.timeout(timeout); + final timeoutFuture = Completer().future.timeout(timeout); final response = await Future.any([inner.send(request), timeoutFuture]); return replaceStream( response, streamTotalTimeout(response.stream, timeoutFuture)); @@ -91,7 +90,7 @@ class VariableTimeoutHttpClient extends TimeoutHttpClient { @override Future send(http.BaseRequest request, - {Duration timeout}) async { + {Duration? timeout}) async { try { final response = await super.send(request); return replaceStream(response, (() async* {