diff --git a/components/model/httptransport/curlrt.go b/components/model/httptransport/curlrt.go index f23345c..75e4c23 100644 --- a/components/model/httptransport/curlrt.go +++ b/components/model/httptransport/curlrt.go @@ -249,11 +249,11 @@ func newLoggingReadCloser(rc io.ReadCloser, ctx context.Context, c *CurlRT) io.R if c.ctxLogger == nil { buf = &bytes.Buffer{} } - cap := c.maxStreamLogBytes - if cap <= 0 { - cap = 8192 + ca := c.maxStreamLogBytes + if ca <= 0 { + ca = 8192 } - return &loggingReadCloser{rc: rc, ctx: ctx, l: c.logger, cl: c.ctxLogger, cap: cap, summary: buf} + return &loggingReadCloser{rc: rc, ctx: ctx, l: c.logger, cl: c.ctxLogger, cap: ca, summary: buf} } func (lrc *loggingReadCloser) Read(p []byte) (int, error) { diff --git a/components/model/httptransport/example/invoke/main.go b/components/model/httptransport/example/invoke/main.go index ce4b671..db93ce6 100644 --- a/components/model/httptransport/example/invoke/main.go +++ b/components/model/httptransport/example/invoke/main.go @@ -26,7 +26,7 @@ import ( "github.com/cloudwego/eino-ext/components/model/openai" "github.com/cloudwego/eino/schema" - httptransport "github.com/cloudwego/eino-examples/components/model/httptransport" + "github.com/cloudwego/eino-examples/components/model/httptransport" ) func main() { diff --git a/components/model/httptransport/example/stream/main.go b/components/model/httptransport/example/stream/main.go index 104d3f0..901d7f4 100644 --- a/components/model/httptransport/example/stream/main.go +++ b/components/model/httptransport/example/stream/main.go @@ -28,7 +28,7 @@ import ( "github.com/cloudwego/eino-ext/components/model/openai" "github.com/cloudwego/eino/schema" - httptransport "github.com/cloudwego/eino-examples/components/model/httptransport" + "github.com/cloudwego/eino-examples/components/model/httptransport" ) func main() {