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

// Copyright 2023 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/streams/byte_stream_tee_engine.h"

#include "third_party/blink/renderer/bindings/core/v8/script_function.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/miscellaneous_operations.h"
#include "third_party/blink/renderer/core/streams/promise_handler.h"
#include "third_party/blink/renderer/core/streams/read_into_request.h"
#include "third_party/blink/renderer/core/streams/read_request.h"
#include "third_party/blink/renderer/core/streams/readable_byte_stream_controller.h"
#include "third_party/blink/renderer/core/streams/readable_stream.h"
#include "third_party/blink/renderer/core/streams/readable_stream_byob_reader.h"
#include "third_party/blink/renderer/core/streams/readable_stream_byob_request.h"
#include "third_party/blink/renderer/core/streams/readable_stream_default_reader.h"
#include "third_party/blink/renderer/core/streams/stream_algorithms.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/wtf/functional.h"

namespace blink {

class ByteStreamTeeEngine::PullAlgorithm final : public StreamAlgorithm { … };

class ByteStreamTeeEngine::CancelAlgorithm final : public StreamAlgorithm { … };

class ByteStreamTeeEngine::ByteTeeReadRequest final : public ReadRequest { … };

class ByteStreamTeeEngine::ByteTeeReadIntoRequest final
    : public ReadIntoRequest { … };

void ByteStreamTeeEngine::ForwardReaderError(
    ScriptState* script_state,
    ReadableStreamGenericReader* this_reader) { … }

void ByteStreamTeeEngine::PullWithDefaultReader(
    ScriptState* script_state,
    ExceptionState& exception_state) { … }

void ByteStreamTeeEngine::PullWithBYOBReader(ScriptState* script_state,
                                             NotShared<DOMArrayBufferView> view,
                                             bool for_branch_2,
                                             ExceptionState& exception_state) { … }

DOMUint8Array* ByteStreamTeeEngine::CloneAsUint8Array(
    DOMArrayBufferView* chunk) { … }

void ByteStreamTeeEngine::Start(ScriptState* script_state,
                                ReadableStream* stream,
                                ExceptionState& exception_state) { … }

}  // namespace blink