fromStream static method

Future<Response> fromStream(StreamedResponse response)

Creates a new HTTP response by waiting for the full body to become available from a StreamedResponse.

Implementation

static Future<Response> fromStream(StreamedResponse response) async {
  // Future that collects the body bytes from the response stream.
  final collectBodyBytes = response.stream.toBytes();

  // We can automatically track a response timeout here, if there is one
  // specified.
  late final Uint8List body;

  if (response.request?.controller != null &&
      response.request!.controller!
          .hasTimeoutForLifecycleState(RequestLifecycleState.receiving)) {
    body = await maybeTrack(
      collectBodyBytes.timeout(response.request!.controller!
          .timeoutForLifecycleState(RequestLifecycleState.receiving)!),
      tracker:
          response.request!.controller!.getExistingTracker(response.request!),
      state: RequestLifecycleState.receiving,
      onCancel: (_) {
        if (response is ClosableStreamedResponse) {
          response.close();
        }
      },
    );
  } else {
    body = await collectBodyBytes;
  }

  return Response.bytes(body, response.statusCode,
      request: response.request,
      headers: response.headers,
      isRedirect: response.isRedirect,
      persistentConnection: response.persistentConnection,
      reasonPhrase: response.reasonPhrase);
}