Modify PeerConnection for end-to-end QuicDataChannel usage

webrtc/p2p/quic/reliablequicstream.cc

Index: webrtc/p2p/quic/reliablequicstream.cc
diff --git a/webrtc/p2p/quic/reliablequicstream.cc b/webrtc/p2p/quic/reliablequicstream.cc
index ca2e3f0d3be3a4475dd6ab5b546eef6c82d281c1..403ad3fcb9c3973e51c2ec3e6bdecf902c8ec267 100644
--- a/webrtc/p2p/quic/reliablequicstream.cc
+++ b/webrtc/p2p/quic/reliablequicstream.cc
@@ -12,6 +12,7 @@
 
 #include <string>
 
+#include "net/quic/quic_session.h"
 #include "webrtc/base/checks.h"
 
 namespace cricket {
@@ -38,9 +39,11 @@ void ReliableQuicStream::OnClose() {
   SignalClosed(id(), connection_error());
 }
 
-rtc::StreamResult ReliableQuicStream::Write(const char* data, size_t len) {
+rtc::StreamResult ReliableQuicStream::Write(const char* data,
+                                            size_t len,
+                                            bool fin) {
   // Writes the data, or buffers it.
-  WriteOrBufferData(std::string(data, len), false, nullptr);
+  WriteOrBufferData(std::string(data, len), fin, nullptr);
   if (HasBufferedData()) {
     return rtc::StreamResult(rtc::SR_BLOCK);
   }
@@ -48,4 +51,8 @@ rtc::StreamResult ReliableQuicStream::Write(const char* data, size_t len) {
   return rtc::StreamResult(rtc::SR_SUCCESS);
 }
 
+void ReliableQuicStream::Close() {
+  net::ReliableQuicStream::session()->CloseStream(id());
+}
+
 }  // namespace cricket