From f1cf153e8d0543c84a1a555e5460ea69ee3c654e Mon Sep 17 00:00:00 2001 From: Zhuowei Wang Date: Mon, 21 Oct 2024 17:43:29 +0800 Subject: [PATCH] chore: fix lint --- pkg/remote/trans/streamx/server_handler.go | 2 +- pkg/streamx/provider/ttstream/transport.go | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/pkg/remote/trans/streamx/server_handler.go b/pkg/remote/trans/streamx/server_handler.go index 10ebda1412..99a0ae069c 100644 --- a/pkg/remote/trans/streamx/server_handler.go +++ b/pkg/remote/trans/streamx/server_handler.go @@ -93,7 +93,7 @@ func (t *svrTransHandler) OnActive(ctx context.Context, conn net.Conn) (context. return ctx, nil } -// OnRead control the connnection level lifecycle. +// OnRead control the connection level lifecycle. // only when OnRead return, netpoll can close the connection buffer func (t *svrTransHandler) OnRead(ctx context.Context, conn net.Conn) (err error) { var wg sync.WaitGroup diff --git a/pkg/streamx/provider/ttstream/transport.go b/pkg/streamx/provider/ttstream/transport.go index 0b1bb09c69..97a58c7797 100644 --- a/pkg/streamx/provider/ttstream/transport.go +++ b/pkg/streamx/provider/ttstream/transport.go @@ -28,9 +28,10 @@ import ( "github.com/bytedance/gopkg/lang/mcache" "github.com/cloudwego/gopkg/bufiox" "github.com/cloudwego/gopkg/protocol/thrift" - "github.com/cloudwego/kitex/pkg/rpcinfo" "github.com/cloudwego/netpoll" + "github.com/cloudwego/kitex/pkg/rpcinfo" + "github.com/cloudwego/kitex/client/streamxclient/streamxcallopt" "github.com/cloudwego/kitex/pkg/klog"