hotfix: add cancelRead to explicitly reset stream

go.mod

@@ -1,6 +1,6 @@
 module github.com/quic-s/quics-protocol
 
-go 1.20
+go 1.21
 
 require (
 	github.com/google/uuid v1.4.0

pkg/connection/connection.go

@@ -75,33 +75,25 @@ func (c *Connection) OpenTransaction(transactionName string, transactionFunc fun
 	newStream, err := qpStream.New(c.logLevel, stream)
 	if err != nil {
 		newStream.SendError(err.Error())
-		newStream.Close()
 		return err
 	}
+	defer newStream.Close()
 
 	transactionID, err := uuid.New().MarshalBinary()
 	if err != nil {
 		newStream.SendError(err.Error())
-		newStream.Close()
 		return err
 	}
 
 	err = TransactionHandshake(newStream, transactionName, transactionID)
 	if err != nil {
 		newStream.SendError(err.Error())
-		newStream.Close()
 		return err
 	}
 
 	err = transactionFunc(newStream, transactionName, transactionID)
 	if err != nil {
 		newStream.SendError(err.Error())
-		newStream.Close()
-		return err
-	}
-
-	err = newStream.Close()
-	if err != nil {
 		return err
 	}
 

pkg/handler/handler.go

@@ -43,13 +43,7 @@ func (h *Handler) RouteTransaction(conn *qpConn.Connection) error {
 			return err
 		}
 		go func() {
-			defer func() {
-				err = stream.Close()
-				if err != nil {
-					log.Println("quics-protocol: ", err)
-				}
-			}()
-
+			defer stream.Close()
 			transaction, err := qpConn.RecvTransactionHandshake(stream)
 			if err != nil {
 				log.Println("quics-protocol: ", err)

pkg/stream/stream.go

@@ -45,6 +45,7 @@ func (s *Stream) Close() error {
 	if s == nil || s.Stream == nil {
 		return errors.New("stream is nil")
 	}
+	s.Stream.CancelRead(0)
 	err := s.Stream.Close()
 	if err != nil {
 		return err