pipe_to_engine.cc | Explore in Territory

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

#include "third_party/blink/renderer/core/streams/pipe_to_engine.h"

#include "third_party/blink/renderer/bindings/core/v8/script_function.h"
#include "third_party/blink/renderer/core/dom/abort_signal.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/pipe_options.h"
#include "third_party/blink/renderer/core/streams/promise_handler.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_byob_reader.h"
#include "third_party/blink/renderer/core/streams/writable_stream.h"
#include "third_party/blink/renderer/core/streams/writable_stream_default_writer.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 PipeToEngine::PipeToAbortAlgorithm final : public AbortSignal::Algorithm { … };

class PipeToEngine::PipeToReadRequest final : public ReadRequest { … };

class PipeToEngine::WrappedPromiseReaction final
    : public PromiseHandlerWithValue { … };

ScriptPromise<IDLUndefined> PipeToEngine::Start(
    ReadableStream* readable,
    WritableStream* destination,
    ExceptionState& exception_state) { … }

bool PipeToEngine::CheckInitialState() { … }

void PipeToEngine::AbortAlgorithm(AbortSignal* signal) { … }

v8::Local<v8::Promise> PipeToEngine::AbortAlgorithmAction() { … }

v8::Local<v8::Value> PipeToEngine::HandleNextEvent(v8::Local<v8::Value>) { … }

void PipeToEngine::ReadRequestChunkStepsBody(ScriptState* script_state,
                                             v8::Global<v8::Value> chunk) { … }

v8::Local<v8::Value> PipeToEngine::OnReaderClosed(v8::Local<v8::Value>) { … }

v8::Local<v8::Value> PipeToEngine::ReadableError(v8::Local<v8::Value> error) { … }

v8::Local<v8::Value> PipeToEngine::WritableError(v8::Local<v8::Value> error) { … }

void PipeToEngine::ReadableClosed() { … }

void PipeToEngine::WritableStartedClosed() { … }

void PipeToEngine::ShutdownWithAction(
    Action action,
    v8::MaybeLocal<v8::Value> original_error) { … }

void PipeToEngine::Shutdown(v8::MaybeLocal<v8::Value> error_maybe) { … }

v8::Local<v8::Value> PipeToEngine::FinalizeWithOriginalErrorIfSet(
    v8::Local<v8::Value>) { … }

v8::Local<v8::Value> PipeToEngine::FinalizeWithNewError(
    v8::Local<v8::Value> new_error) { … }

void PipeToEngine::Finalize(v8::MaybeLocal<v8::Value> error_maybe) { … }

bool PipeToEngine::ShouldWriteQueuedChunks() const { … }

v8::Local<v8::Promise> PipeToEngine::WriteQueuedChunks() { … }

v8::Local<v8::Promise> PipeToEngine::WritableStreamAbortAction() { … }

v8::Local<v8::Promise> PipeToEngine::ReadableStreamCancelAction() { … }

v8::Local<v8::Promise>
PipeToEngine::WritableStreamDefaultWriterCloseWithErrorPropagationAction() { … }

WritableStream* PipeToEngine::Destination() { … }

const WritableStream* PipeToEngine::Destination() const { … }

ReadableStream* PipeToEngine::Readable() { … }

v8::Local<v8::Promise> PipeToEngine::ThenPromise(v8::Local<v8::Promise> promise,
                                                 PromiseReaction on_fulfilled,
                                                 PromiseReaction on_rejected) { … }

}  // namespace blink
chromium/third_party/blink/renderer/core/streams/pipe_to_engine.cc
