We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5442307 commit 4937ae2Copy full SHA for 4937ae2
pkgs/http/lib/src/io_client.dart
@@ -98,7 +98,24 @@ class IOClient extends BaseClient {
98
ioRequest.headers.set(name, value);
99
});
100
101
- var response = await stream.pipe(ioRequest) as HttpClientResponse;
+ HttpClientResponse response;
102
+ if (onSendProgress != null) {
103
+ var loaded = 0;
104
+ onSendProgress(loaded, request.contentLength);
105
+
106
+ await ioRequest.addStream(
107
+ stream.map(
108
+ (chunk) {
109
+ loaded += chunk.length;
110
111
+ return chunk;
112
+ },
113
+ ),
114
+ );
115
+ response = await ioRequest.close();
116
+ } else {
117
+ response = await stream.pipe(ioRequest) as HttpClientResponse;
118
+ }
119
120
var headers = <String, String>{};
121
response.headers.forEach((key, values) {
0 commit comments