diff --git a/pkg/dev/options.go b/pkg/dev/options.go index 9bd06cd0..b7552fee 100644 --- 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 index c899556b..88a69615 100644 --- 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 }