chromium/third_party/blink/renderer/platform/loader/fetch/data_pipe_bytes_consumer.cc

// Copyright 2018 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/platform/loader/fetch/data_pipe_bytes_consumer.h"

#include <algorithm>

#include "base/containers/span.h"
#include "base/location.h"
#include "base/numerics/safe_conversions.h"
#include "base/task/single_thread_task_runner.h"
#include "third_party/blink/public/platform/task_type.h"
#include "third_party/blink/renderer/platform/heap/persistent.h"
#include "third_party/blink/renderer/platform/wtf/functional.h"

namespace blink {

void DataPipeBytesConsumer::CompletionNotifier::SignalComplete() { … }

void DataPipeBytesConsumer::CompletionNotifier::SignalSize(uint64_t size) { … }

void DataPipeBytesConsumer::CompletionNotifier::SignalError(
    const BytesConsumer::Error& error) { … }

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

DataPipeBytesConsumer::DataPipeBytesConsumer(
    scoped_refptr<base::SingleThreadTaskRunner> task_runner,
    mojo::ScopedDataPipeConsumerHandle data_pipe,
    CompletionNotifier** notifier)
    : … { … }

DataPipeBytesConsumer::~DataPipeBytesConsumer() { … }

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

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

mojo::ScopedDataPipeConsumerHandle DataPipeBytesConsumer::DrainAsDataPipe() { … }

void DataPipeBytesConsumer::SetClient(BytesConsumer::Client* client) { … }

void DataPipeBytesConsumer::ClearClient() { … }

void DataPipeBytesConsumer::Cancel() { … }

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

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

bool DataPipeBytesConsumer::IsWaiting() const { … }

void DataPipeBytesConsumer::MaybeClose() { … }

void DataPipeBytesConsumer::SignalComplete() { … }

void DataPipeBytesConsumer::SignalSize(uint64_t size) { … }

void DataPipeBytesConsumer::SignalError(const Error& error) { … }

void DataPipeBytesConsumer::SetError(const Error& error) { … }

void DataPipeBytesConsumer::Notify(MojoResult) { … }

void DataPipeBytesConsumer::ClearDataPipe() { … }

void DataPipeBytesConsumer::Dispose() { … }

}  // namespace blink