From afba7a45c94c948ba0ceb1f92076e8d1aa684a2c Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Fri, 30 Nov 2018 14:43:51 +0100 Subject: [PATCH] add missing files --- vendor/github.com/lucas-clemente/quic-go/interface.go | 4 ++++ vendor/github.com/lucas-clemente/quic-go/receive_stream.go | 7 +++++++ 2 files changed, 11 insertions(+) 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()