toStreamedRequest function
Implementation
@visibleForTesting
Future<http.StreamedRequest> toStreamedRequest(
Stream<List<int>> bodyStream,
String method,
Uri uri,
Map<String, String> headers,
) async {
final req = http.StreamedRequest(method, uri);
req.headers.addAll(headers);
bodyStream.listen(req.sink.add,
onDone: req.sink.close, onError: req.sink.addError);
return req;
}