Commit

Author: R4R3D1FF

handler.go

@@ -256,10 +256,11 @@ func NewBidiStreamHandler[Req, Res any](
 
 // ServeHTTP implements [http.Handler].
 func (h *Handler) ServeHTTP(responseWriter http.ResponseWriter, request *http.Request) {
-
-	rc := http.NewResponseController(responseWriter)
-	rc.SetReadDeadline(time.Now().Add(time.Duration(h.spec.ReadTimeout) * time.Nanosecond))
-	rc.SetWriteDeadline(time.Now().Add(time.Duration(h.spec.ReadTimeout) * time.Nanosecond))
+	if h.spec.ReadTimeout != 0 {
+		rc := http.NewResponseController(responseWriter)
+		rc.SetReadDeadline(time.Now().Add(time.Duration(h.spec.ReadTimeout) * time.Nanosecond))
+		rc.SetWriteDeadline(time.Now().Add(time.Duration(h.spec.ReadTimeout) * time.Nanosecond))
+	}
 
 	// We don't need to defer functions to close the request body or read to
 	// EOF: the stream we construct later on already does that, and we only