send method

@override Future<StreamedResponse> send(BaseRequest request)

Sends an HTTP request and asynchronously returns the response.

Implementers should call BaseRequest.finalize to get the body of the request as a ByteStream. They shouldn't make any assumptions about the state of the stream; it could have data written to it asynchronously at a later point, or it could already be closed when it's returned. Any internal HTTP errors should be wrapped as ClientExceptions.

Implementation

@override
Future<http.StreamedResponse> send(http.BaseRequest request) async {
  if (_authClient != null) {
    return await _authClient!.send(request);
  }
  final response = await _inner.send(request);

  if (response.statusCode == 401) {
    final authHeader = response.headers[HttpConstants.headerWwwAuthenticate]!;
    final scheme = pickSchemeFromAuthenticateHeader(authHeader);
    switch (scheme) {
      case AuthenticationScheme.basic:
        _authClient = BasicAuthClient(_username, _password, inner: _inner);
        break;
      case AuthenticationScheme.digest:
        _authClient = DigestAuthClient(_username, _password,
            inner: _inner, authenticationHeader: authHeader);
        break;
      default:
        throw StateError(
            'Unsupported authenticate scheme in WWW-Authenticate header $authHeader');
    }
    final newRequest = copyRequest(request);

    return await _authClient!.send(newRequest);
  }

  return response;
}