add a Remote field to the StreamError

errors.go

@@ -55,6 +55,7 @@ const WebTransportBufferedStreamRejectedErrorCode quic.StreamErrorCode = 0x3994b
 // StreamError is the error that is returned from stream operations (Read, Write) when the stream is canceled.
 type StreamError struct {
 	ErrorCode StreamErrorCode
+	Remote    bool
 }
 
 func (e *StreamError) Is(target error) bool {

stream.go

@@ -200,7 +200,10 @@ func maybeConvertStreamError(err error) error {
 		if cerr != nil {
 			return fmt.Errorf("stream reset, but failed to convert stream error %d: %w", streamErr.ErrorCode, cerr)
 		}
-		return &StreamError{ErrorCode: errorCode}
+		return &StreamError{
+			ErrorCode: errorCode,
+			Remote:    streamErr.Remote,
+		}
 	}
 	return err
 }

webtransport_test.go

@@ -360,6 +360,7 @@ func TestMultipleClients(t *testing.T) {
 
 func TestStreamResetError(t *testing.T) {
 	const errorCode webtransport.StreamErrorCode = 127
+	strChan := make(chan webtransport.Stream, 1)
 	sess, closeServer := establishSession(t, func(sess *webtransport.Session) {
 		for {
 			str, err := sess.AcceptStream(context.Background())
@@ -368,10 +369,12 @@ func TestStreamResetError(t *testing.T) {
 			}
 			str.CancelRead(errorCode)
 			str.CancelWrite(errorCode)
+			strChan <- str
 		}
 	})
 	defer closeServer()
 
+	// client side
 	str, err := sess.OpenStream()
 	require.NoError(t, err)
 	_, err = str.Write([]byte("foobar"))
@@ -381,6 +384,15 @@ func TestStreamResetError(t *testing.T) {
 	var strErr *webtransport.StreamError
 	require.True(t, errors.As(err, &strErr))
 	require.Equal(t, strErr.ErrorCode, errorCode)
+	require.True(t, strErr.Remote)
+
+	// server side
+	str = <-strChan
+	_, err = str.Read([]byte{0})
+	require.Error(t, err)
+	require.True(t, errors.As(err, &strErr))
+	require.Equal(t, strErr.ErrorCode, errorCode)
+	require.False(t, strErr.Remote)
 }
 
 func TestShutdown(t *testing.T) {