toStreamedRequest function

  1. @visibleForTesting
Future<StreamedRequest> toStreamedRequest(
  1. Stream<List<int>> bodyStream,
  2. String method,
  3. Uri uri,
  4. Map<String, String> headers,
)

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;
}