We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7c131a0 commit 278cadfCopy full SHA for 278cadf
lib/src/io_client.dart
@@ -45,7 +45,24 @@ class IOClient extends BaseClient {
45
ioRequest.headers.set(name, value);
46
});
47
48
- var response = await stream.pipe(ioRequest) as HttpClientResponse;
+ HttpClientResponse response;
49
+ if (onSendProgress != null) {
50
+ var loaded = 0;
51
+ onSendProgress(loaded, request.contentLength);
52
+
53
+ await ioRequest.addStream(
54
+ stream.map(
55
+ (chunk) {
56
+ loaded += chunk.length;
57
58
+ return chunk;
59
+ },
60
+ ),
61
+ );
62
+ response = await ioRequest.close();
63
+ } else {
64
+ response = await stream.pipe(ioRequest) as HttpClientResponse;
65
+ }
66
67
var headers = <String, String>{};
68
response.headers.forEach((key, values) {
0 commit comments