Define Stable API for WebRTC/Quartc

net/quic/quartc/quartc_reliable_stream.cc

+// Copyright (c) 2012 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#include "net/quic/quartc/quartc_reliable_stream.h"
+
+namespace net {
+
+QuartcReliableStream::QuartcReliableStream(QuicStreamId id,
+                                           QuicSession* session)
+    : ReliableQuicStream(id, session) {}
+QuartcReliableStream::~QuartcReliableStream() {}
+
+void QuartcReliableStream::OnDataAvailable() {
+  struct iovec iov;
+  while (sequencer()->GetReadableRegions(&iov, 1) == 1) {
+    DCHECK(observer_);
+    observer_->OnReceived(this, reinterpret_cast<const char*>(iov.iov_base),
+                          iov.iov_len);
+    sequencer()->MarkConsumed(iov.iov_len);
+  }
+}
+
+void QuartcReliableStream::OnClose() {
+  ReliableQuicStream::OnClose();
+  DCHECK(observer_);
+  observer_->OnClose(this, connection_error());
+}
+
+void QuartcReliableStream::OnCanWrite() {
+  ReliableQuicStream::OnCanWrite();
+  DCHECK(observer_);
+  observer_->OnBufferedAmountChanged(this);
+}
+
+uint32_t QuartcReliableStream::stream_id() {
+  return id();
+}
+
+uint64_t QuartcReliableStream::buffered_amount() {
+  return queued_data_bytes();
+}
+
+void QuartcReliableStream::Write(const char* data,
+                                 size_t size,
+                                 const WriteParameters& param) {
+  WriteOrBufferData(base::StringPiece(data, size), param.fin, nullptr);
+}
+
+void QuartcReliableStream::Close() {
+  ReliableQuicStream::session()->CloseStream(id());
+}
+
+void QuartcReliableStream::SetObserver(
+    QuartcReliableStream::Observer* observer) {
+  observer_ = observer;
+}
+
+}  // namespace net