toStreamedRequest method

  1. @visibleForTesting
StreamedRequest toStreamedRequest(
  1. Stream<List<int>> bodyStream
)

Convert this Request to a http.StreamedRequest

Implementation

@visibleForTesting
http.StreamedRequest toStreamedRequest(Stream<List<int>> bodyStream) {
  final http.StreamedRequest request = http.StreamedRequest(method, url)
    ..headers.addAll(headers);

  bodyStream.listen(
    request.sink.add,
    onDone: request.sink.close,
    onError: request.sink.addError,
  );

  return request;
}