hotfix: fix print grpc msg bug

kubenetworks · Dec 13, 2024 · 125b30a · 125b30a
1 parent 5599dc6
commit 125b30a
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 14 deletions.
diff --git a/pkg/dev/options.go b/pkg/dev/options.go
@@ -330,15 +330,6 @@ func (option *Options) Dev(ctx context.Context, cConfig *Config, hostConfig *Hos
 	return configList.Run(ctx, volume, option.cli, option.dockerCli)
 }
 
-func disconnect(ctx context.Context, daemonClient rpc.DaemonClient, req *rpc.DisconnectRequest) error {
-	resp, err := daemonClient.Disconnect(ctx, req)
-	if err != nil {
-		return err
-	}
-	err = util.PrintGRPCStream[rpc.DisconnectResponse](resp)
-	return err
-}
-
 func (option *Options) CreateConnectContainer(portBindings nat.PortMap) (*RunConfig, error) {
 	portMap, portSet, err := option.GetExposePort(portBindings)
 	if err != nil {

diff --git a/pkg/util/grpc.go b/pkg/util/grpc.go
@@ -8,8 +8,6 @@ import (
 	"os"
 
 	"google.golang.org/grpc"
-	"google.golang.org/grpc/codes"
-	"google.golang.org/grpc/status"
 )
 
 type Printable interface {
@@ -29,9 +27,6 @@ func PrintGRPCStream[T any](clientStream grpc.ClientStream, writers ...io.Writer
 		if errors.Is(err, io.EOF) {
 			return nil
 		}
-		if status.Code(err) == codes.Canceled {
-			return nil
-		}
 		if err != nil {
 			return err
 		}