Skip to content

Commit 2930a17

Browse files
committed
perf: stream request body
Signed-off-by: Danny Kopping <danny@coder.com>
1 parent 14690bd commit 2930a17

File tree

1 file changed

+1
-7
lines changed

1 file changed

+1
-7
lines changed

provider/anthropic.go

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ package provider
33
import (
44
"encoding/json"
55
"fmt"
6-
"io"
76
"net/http"
87
"os"
98

@@ -61,15 +60,10 @@ func (p *Anthropic) CreateInterceptor(w http.ResponseWriter, r *http.Request, tr
6160
_, span := tracer.Start(r.Context(), "Intercept.CreateInterceptor")
6261
defer tracing.EndSpanErr(span, &outErr)
6362

64-
payload, err := io.ReadAll(r.Body)
65-
if err != nil {
66-
return nil, fmt.Errorf("read body: %w", err)
67-
}
68-
6963
switch r.URL.Path {
7064
case routeMessages:
7165
var req messages.MessageNewParamsWrapper
72-
if err := json.Unmarshal(payload, &req); err != nil {
66+
if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
7367
return nil, fmt.Errorf("failed to unmarshal request: %w", err)
7468
}
7569

0 commit comments

Comments
 (0)