chromium/third_party/blink/renderer/modules/serial/serial_port_underlying_source.cc

// Copyright 2019 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/serial/serial_port_underlying_source.h"

#include "base/numerics/safe_conversions.h"
#include "third_party/blink/renderer/bindings/core/v8/script_promise_resolver.h"
#include "third_party/blink/renderer/bindings/core/v8/v8_throw_dom_exception.h"
#include "third_party/blink/renderer/core/streams/readable_byte_stream_controller.h"
#include "third_party/blink/renderer/core/streams/readable_stream_byob_request.h"
#include "third_party/blink/renderer/core/typed_arrays/dom_array_piece.h"
#include "third_party/blink/renderer/core/typed_arrays/dom_typed_array.h"
#include "third_party/blink/renderer/modules/serial/serial_port.h"
#include "third_party/blink/renderer/platform/bindings/exception_code.h"
#include "third_party/blink/renderer/platform/wtf/functional.h"

namespace blink {

namespace {
SerialReceiveError;
}

SerialPortUnderlyingSource::SerialPortUnderlyingSource(
    ScriptState* script_state,
    SerialPort* serial_port,
    mojo::ScopedDataPipeConsumerHandle handle)
    : … { … }

ScriptPromise<IDLUndefined> SerialPortUnderlyingSource::Pull(
    ReadableByteStreamController* controller,
    ExceptionState&) { … }

ScriptPromise<IDLUndefined> SerialPortUnderlyingSource::Cancel(
    ExceptionState& exception_state) { … }

ScriptPromise<IDLUndefined> SerialPortUnderlyingSource::Cancel(
    v8::Local<v8::Value> reason,
    ExceptionState& exception_state) { … }

ScriptState* SerialPortUnderlyingSource::GetScriptState() { … }

void SerialPortUnderlyingSource::ContextDestroyed() { … }

void SerialPortUnderlyingSource::SignalErrorOnClose(SerialReceiveError error) { … }

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

void SerialPortUnderlyingSource::ReadDataOrArmWatcher() { … }

void SerialPortUnderlyingSource::OnHandleReady(
    MojoResult result,
    const mojo::HandleSignalsState& state) { … }

void SerialPortUnderlyingSource::OnFlush(
    ScriptPromiseResolver<IDLUndefined>* resolver) { … }

void SerialPortUnderlyingSource::PipeClosed() { … }

void SerialPortUnderlyingSource::Close() { … }

}  // namespace blink