chromium/third_party/blink/renderer/core/fetch/readable_stream_bytes_consumer.cc

// Copyright 2016 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/core/fetch/readable_stream_bytes_consumer.h"

#include <string.h>

#include <algorithm>

#include "third_party/blink/renderer/bindings/core/v8/native_value_traits_impl.h"
#include "third_party/blink/renderer/core/execution_context/agent.h"
#include "third_party/blink/renderer/core/execution_context/execution_context.h"
#include "third_party/blink/renderer/core/streams/read_request.h"
#include "third_party/blink/renderer/platform/bindings/exception_state.h"
#include "third_party/blink/renderer/platform/bindings/scoped_persistent.h"
#include "third_party/blink/renderer/platform/bindings/script_forbidden_scope.h"
#include "third_party/blink/renderer/platform/bindings/script_state.h"
#include "third_party/blink/renderer/platform/bindings/v8_binding_macros.h"
#include "third_party/blink/renderer/platform/scheduler/public/event_loop.h"
#include "third_party/blink/renderer/platform/wtf/functional.h"
#include "third_party/blink/renderer/platform/wtf/text/wtf_string.h"
#include "v8/include/v8.h"

namespace blink {

class ReadableStreamBytesConsumer::BytesConsumerReadRequest final
    : public ReadRequest { … };

ReadableStreamBytesConsumer::ReadableStreamBytesConsumer(
    ScriptState* script_state,
    ReadableStream* stream)
    : … { … }

ReadableStreamBytesConsumer::~ReadableStreamBytesConsumer() { … }

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

BytesConsumer::Result ReadableStreamBytesConsumer::EndRead(size_t read_size) { … }

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

void ReadableStreamBytesConsumer::ClearClient() { … }

void ReadableStreamBytesConsumer::Cancel() { … }

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

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

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

void ReadableStreamBytesConsumer::OnRead(DOMUint8Array* buffer) { … }

void ReadableStreamBytesConsumer::OnReadDone() { … }

void ReadableStreamBytesConsumer::OnRejected() { … }

void ReadableStreamBytesConsumer::SetErrored() { … }

}  // namespace blink