send method

@override Future<StreamedResponse> send(BaseRequest request)

Sends an HTTP request and asynchronously returns the response.

Implementation

@override
Future<StreamedResponse> send(BaseRequest request) async {
  if (_isClosed) {
    throw ClientException(
        'HTTP request failed. Client is already closed.', request.url);
  }

  final bodyBytes = await request.finalize().toBytes();
  try {
    final response = await window
        .fetch(
          '${request.url}'.toJS,
          RequestInit(
            method: request.method,
            body: bodyBytes.isNotEmpty ? bodyBytes.toJS : null,
            credentials: withCredentials ? 'include' : 'same-origin',
            headers: {
              if (request.contentLength case final contentLength?)
                'content-length': contentLength,
              for (var header in request.headers.entries)
                header.key: header.value,
            }.jsify()! as HeadersInit,
            signal: _abortController.signal,
            redirect: request.followRedirects ? 'follow' : 'error',
          ),
        )
        .toDart;

    final contentLengthHeader = response.headers.get('content-length');

    final contentLength = contentLengthHeader != null
        ? int.tryParse(contentLengthHeader)
        : null;

    if (contentLength == null && contentLengthHeader != null) {
      throw ClientException(
        'Invalid content-length header [$contentLengthHeader].',
        request.url,
      );
    }

    final headers = <String, String>{};
    (response.headers as _IterableHeaders)
        .forEach((String value, String header, [JSAny? _]) {
      headers[header.toLowerCase()] = value;
    }.toJS);

    return StreamedResponseV2(
      _readBody(request, response),
      response.status,
      headers: headers,
      request: request,
      contentLength: contentLength,
      url: Uri.parse(response.url),
      reasonPhrase: response.statusText,
    );
  } catch (e, st) {
    _rethrowAsClientException(e, st, request);
  }
}