chromium/third_party/blink/renderer/modules/direct_sockets/stream_wrapper.cc

// Copyright 2022 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/modules/direct_sockets/stream_wrapper.h"

#include "base/notreached.h"
#include "third_party/blink/renderer/bindings/core/v8/script_promise.h"
#include "third_party/blink/renderer/bindings/core/v8/v8_throw_dom_exception.h"
#include "third_party/blink/renderer/core/dom/abort_signal.h"
#include "third_party/blink/renderer/core/dom/events/event_target_impl.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/underlying_byte_source_base.h"
#include "third_party/blink/renderer/core/streams/underlying_sink_base.h"
#include "third_party/blink/renderer/core/streams/underlying_source_base.h"
#include "third_party/blink/renderer/core/streams/writable_stream.h"
#include "third_party/blink/renderer/core/streams/writable_stream_default_controller.h"
#include "third_party/blink/renderer/platform/bindings/exception_code.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/heap/garbage_collected.h"

namespace blink {

namespace {

class ForwardingUnderlyingSource : public UnderlyingSourceBase { … };

class ForwardingUnderlyingByteSource : public UnderlyingByteSourceBase { … };

class ForwardingUnderlyingSink : public UnderlyingSinkBase { … };

}  // namespace

StreamWrapper::StreamWrapper(ScriptState* script_state)
    : … { … }

StreamWrapper::~StreamWrapper() = default;

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

ReadableStreamWrapper::ReadableStreamWrapper(ScriptState* script_state)
    : … { … }

bool ReadableStreamWrapper::Locked() const { … }

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

ReadableStreamDefaultWrapper::ReadableStreamDefaultWrapper(
    ScriptState* script_state)
    : … { … }

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

// static
UnderlyingSourceBase*
ReadableStreamDefaultWrapper::MakeForwardingUnderlyingSource(
    ReadableStreamDefaultWrapper* readable_stream_wrapper) { … }

ReadableByteStreamWrapper::ReadableByteStreamWrapper(ScriptState* script_state)
    : … { … }

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

// static
UnderlyingByteSourceBase*
ReadableByteStreamWrapper::MakeForwardingUnderlyingByteSource(
    ReadableByteStreamWrapper* readable_stream_wrapper) { … }

WritableStreamWrapper::WritableStreamWrapper(ScriptState* script_state)
    : … { … }

bool WritableStreamWrapper::Locked() const { … }

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

// static
UnderlyingSinkBase* WritableStreamWrapper::MakeForwardingUnderlyingSink(
    WritableStreamWrapper* writable_stream_wrapper) { … }

}  // namespace blink