chromium/third_party/blink/renderer/core/streams/readable_stream_default_reader.cc

// Copyright 2020 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/core/streams/readable_stream_default_reader.h"

#include "third_party/blink/renderer/bindings/core/v8/script_promise.h"
#include "third_party/blink/renderer/bindings/core/v8/v8_readable_stream_read_result.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/core/streams/readable_stream.h"
#include "third_party/blink/renderer/core/streams/readable_stream_default_controller.h"
#include "third_party/blink/renderer/core/streams/stream_promise_resolver.h"
#include "third_party/blink/renderer/platform/bindings/exception_state.h"
#include "third_party/blink/renderer/platform/bindings/script_state.h"
#include "third_party/blink/renderer/platform/bindings/v8_throw_exception.h"

namespace blink {

class ReadableStreamDefaultReader::DefaultReaderReadRequest final
    : public ReadRequest { … };

ReadableStreamDefaultReader* ReadableStreamDefaultReader::Create(
    ScriptState* script_state,
    ReadableStream* stream,
    ExceptionState& exception_state) { … }

ReadableStreamDefaultReader::ReadableStreamDefaultReader(
    ScriptState* script_state,
    ReadableStream* stream,
    ExceptionState& exception_state)
    : … { … }

ReadableStreamDefaultReader::~ReadableStreamDefaultReader() = default;

ScriptPromise<ReadableStreamReadResult> ReadableStreamDefaultReader::read(
    ScriptState* script_state,
    ExceptionState& exception_state) { … }

void ReadableStreamDefaultReader::Read(ScriptState* script_state,
                                       ReadableStreamDefaultReader* reader,
                                       ReadRequest* read_request,
                                       ExceptionState& exception_state) { … }

void ReadableStreamDefaultReader::ErrorReadRequests(
    ScriptState* script_state,
    ReadableStreamDefaultReader* reader,
    v8::Local<v8::Value> e) { … }

void ReadableStreamDefaultReader::Release(ScriptState* script_state,
                                          ReadableStreamDefaultReader* reader) { … }

void ReadableStreamDefaultReader::releaseLock(ScriptState* script_state,
                                              ExceptionState& exception_state) { … }

void ReadableStreamDefaultReader::SetUpDefaultReader(
    ScriptState* script_state,
    ReadableStreamDefaultReader* reader,
    ReadableStream* stream,
    ExceptionState& exception_state) { … }

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

bool ReadableStreamDefaultReader::HasPendingActivity() const { … }

}  // namespace blink