chromium/third_party/blink/renderer/platform/loader/testing/replaying_bytes_consumer.cc

// 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.

#ifdef UNSAFE_BUFFERS_BUILD
// TODO(crbug.com/351564777): Remove this and convert code to safer constructs.
#pragma allow_unsafe_buffers
#endif

#include "third_party/blink/renderer/platform/loader/testing/replaying_bytes_consumer.h"

#include "base/task/single_thread_task_runner.h"
#include "third_party/blink/renderer/platform/heap/persistent.h"
#include "third_party/blink/renderer/platform/wtf/functional.h"

namespace blink {

ReplayingBytesConsumer::ReplayingBytesConsumer(
    scoped_refptr<base::SingleThreadTaskRunner> task_runner)
    : … { … }

ReplayingBytesConsumer::~ReplayingBytesConsumer() { … }

BytesConsumer::Result ReplayingBytesConsumer::BeginRead(const char** buffer,
                                                        size_t* available) { … }

BytesConsumer::Result ReplayingBytesConsumer::EndRead(size_t read) { … }

void ReplayingBytesConsumer::SetClient(Client* client) { … }

void ReplayingBytesConsumer::ClearClient() { … }

void ReplayingBytesConsumer::Cancel() { … }

BytesConsumer::PublicState ReplayingBytesConsumer::GetPublicState() const { … }

BytesConsumer::Error ReplayingBytesConsumer::GetError() const { … }

void ReplayingBytesConsumer::NotifyAsReadable(int notification_token) { … }

void ReplayingBytesConsumer::Close() { … }

void ReplayingBytesConsumer::MakeErrored(const Error& e) { … }

void ReplayingBytesConsumer::Trace(Visitor* visitor) const { … }

}  // namespace blink