1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
// Copyright 2019 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "third_party/blink/renderer/modules/cache_storage/cache_utils.h"
#include <utility>
#include "third_party/blink/renderer/core/fetch/fetch_response_data.h"
#include "third_party/blink/renderer/core/fetch/response.h"
#include "third_party/blink/renderer/modules/cache_storage/cache_storage_blob_client_list.h"
#include "third_party/blink/renderer/platform/loader/fetch/data_pipe_bytes_consumer.h"
namespace blink {
Response* CreateEagerResponse(ScriptState* script_state,
mojom::blink::EagerResponsePtr eager_response,
CacheStorageBlobClientList* client_list) {
auto& response = eager_response->response;
DCHECK(!response->blob);
ExecutionContext* context = ExecutionContext::From(script_state);
FetchResponseData* fetch_data =
Response::CreateUnfilteredFetchResponseDataWithoutBody(script_state,
*response);
DataPipeBytesConsumer::CompletionNotifier* completion_notifier = nullptr;
fetch_data->ReplaceBodyStreamBuffer(BodyStreamBuffer::Create(
script_state,
MakeGarbageCollected<DataPipeBytesConsumer>(
context->GetTaskRunner(TaskType::kNetworking),
std::move(eager_response->pipe), &completion_notifier),
nullptr /* AbortSignal */, /*cached_metadata_handler=*/nullptr,
std::move(response->side_data_blob)));
// Create a BlobReaderClient in the provided list. This will track the
// completion of the eagerly read blob and propagate it to the given
// DataPipeBytesConsumer::CompletionNotifier. The list will also hold
// the client alive.
client_list->AddClient(context, std::move(eager_response->client_receiver),
std::move(completion_notifier));
fetch_data = Response::FilterResponseData(
response->response_type, fetch_data, response->cors_exposed_header_names);
return Response::Create(context, fetch_data);
}
} // namespace blink
|
