diff --git a/vendor/github.com/lucas-clemente/quic-go/interface.go b/vendor/github.com/lucas-clemente/quic-go/interface.go index 5ba909cb9..6342fbb0c 100644 --- a/vendor/github.com/lucas-clemente/quic-go/interface.go +++ b/vendor/github.com/lucas-clemente/quic-go/interface.go @@ -76,6 +76,8 @@ type Stream interface { // with the connection. It is equivalent to calling both // SetReadDeadline and SetWriteDeadline. SetDeadline(t time.Time) error + + HasMoreData() bool } // A ReceiveStream is a unidirectional Receive Stream. @@ -88,6 +90,8 @@ type ReceiveStream interface { CancelRead(ErrorCode) error // see Stream.SetReadDealine SetReadDeadline(t time.Time) error + + HasMoreData() bool } // A SendStream is a unidirectional Send Stream. diff --git a/vendor/github.com/lucas-clemente/quic-go/receive_stream.go b/vendor/github.com/lucas-clemente/quic-go/receive_stream.go index 13674e8ae..76872691a 100644 --- a/vendor/github.com/lucas-clemente/quic-go/receive_stream.go +++ b/vendor/github.com/lucas-clemente/quic-go/receive_stream.go @@ -83,6 +83,13 @@ func (s *receiveStream) Read(p []byte) (int, error) { return n, err } +func (s *receiveStream) HasMoreData() bool { + s.mutex.Lock() + defer s.mutex.Unlock() + + return s.currentFrame != nil +} + func (s *receiveStream) readImpl(p []byte) (bool /*stream completed */, int, error) { s.mutex.Lock() defer s.mutex.Unlock()