Skip to content

Commit ccda051

Browse files
committed
perf: stream request body
Signed-off-by: Danny Kopping <[email protected]>
1 parent 5dc19fc commit ccda051

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

@@ -78,15 +77,10 @@ func (p *Anthropic) CreateInterceptor(w http.ResponseWriter, r *http.Request, tr
7877
_, span := tracer.Start(r.Context(), "Intercept.CreateInterceptor")
7978
defer tracing.EndSpanErr(span, &outErr)
8079

81-
payload, err := io.ReadAll(r.Body)
82-
if err != nil {
83-
return nil, fmt.Errorf("read body: %w", err)
84-
}
85-
8680
switch r.URL.Path {
8781
case routeMessages:
8882
var req messages.MessageNewParamsWrapper
89-
if err := json.Unmarshal(payload, &req); err != nil {
83+
if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
9084
return nil, fmt.Errorf("failed to unmarshal request: %w", err)
9185
}
9286

0 commit comments

Comments
 (0)