diff --git a/grpc.go b/grpc.go index b8294f6..4549c7a 100644 --- a/grpc.go +++ b/grpc.go @@ -10,7 +10,6 @@ import ( "slices" "sort" "strconv" - "strings" "sync" "sync/atomic" "time" @@ -19,7 +18,7 @@ import ( reflectionv1pb "google.golang.org/grpc/reflection/grpc_reflection_v1" // nolint: staticcheck - "go.unistack.org/micro/v4/codec" + "go.unistack.org/micro/v4/errors" "go.unistack.org/micro/v4/logger" "go.unistack.org/micro/v4/metadata" @@ -519,21 +518,6 @@ func (g *Server) processStream(ctx context.Context, stream grpc.ServerStream, se return status.New(statusCode, statusDesc).Err() } -func (g *Server) newCodec(ct string) (codec.Codec, error) { - g.RLock() - defer g.RUnlock() - - if idx := strings.IndexRune(ct, ';'); idx >= 0 { - ct = ct[:idx] - } - - if c, ok := g.opts.Codecs[ct]; ok { - return c, nil - } - - return nil, codec.ErrUnknownContentType -} - func (g *Server) Options() server.Options { g.RLock() opts := g.opts