stream & error

util/error.go

@@ -0,0 +1,9 @@
+package util
+
+import "errors"
+
+func IsErrorLike(left, right error) bool {
+	return left == nil && right == nil ||
+		left != nil && right != nil && left.Error() == right.Error() ||
+		errors.Is(left, right)
+}

util/http_handler_stream.go

@@ -1,6 +1,7 @@
 package util
 
 import (
+	"context"
 	"errors"
 	"net/http"
 	"time"
@@ -36,9 +37,15 @@ func StreamHandlerWrap(
 		}); err != nil {
 			if errors.Is(err, ErrHandledAndBreak) {
 				HttpLog(r, start, 200, err)
-			} else if errors.Is(err, StreamEof) {
+				// } else if errors.Is(err, StreamEof) {
+			} else if IsErrorLike(err, StreamEof) {
 				// noop
 				HttpLog(r, start, 200, nil)
+			} else if errors.Is(err, context.DeadlineExceeded) {
+				// ignore
+				w.Write([]byte("..."))
+				flusher.Flush()
+				HttpLog(r, start, 200, nil)
 			} else {
 				if e, ok := err.(IStatusError); ok && e.Status() < 500 {
 					SendErrText(w, err)