Add BufferedDataBytes API for QuicStream. (#552)

Author: taste1981

talk/owt/sdk/base/stream.cc

@@ -730,7 +730,7 @@ QuicStream::~QuicStream() {
 }
 
 size_t QuicStream::Write(uint8_t* data, size_t length) {
-  if (quic_stream_ && !fin_read_ && data != nullptr && length > 0) {
+  if (quic_stream_ && data != nullptr && length > 0) {
     return quic_stream_->Write(data, length);
   }
   return 0;
@@ -752,6 +752,14 @@ size_t QuicStream::ReadableBytes() const {
   }
 }
 
+uint64_t QuicStream::BufferedDataBytes() const {
+  if (quic_stream_) {
+    return quic_stream_->BufferedDataBytes();
+  } else {
+    return 0;
+  }
+}
+
 std::shared_ptr<owt::base::QuicStream> LocalStream::Stream() {
   return quic_stream_;
 }

talk/owt/sdk/include/cpp/owt/base/stream.h

@@ -207,6 +207,11 @@ class QuicStream : public owt::quic::WebTransportStreamInterface::Visitor {
    @return Bytes of data available on the stream.
   */
   size_t ReadableBytes() const;
+  /**
+   @brief Returns the amount of data pending to be sent on the stream.
+   @return Bytes of data pending to be sent.
+  */
+  uint64_t BufferedDataBytes() const;
   void SetVisitor(owt::quic::WebTransportStreamInterface::Visitor* visitor) {
     if (quic_stream_ && visitor) {
       quic_stream_->SetVisitor(visitor);
@@ -224,7 +229,6 @@ class QuicStream : public owt::quic::WebTransportStreamInterface::Visitor {
     // OnFinRead the stream is no longer readable/writable
     fin_read_ = true;
     can_read_ = false;
-    can_write_ = false;
   }
   /** @endcond */
  private: