diff --git a/grpc.go b/grpc.go index 4af9101..1e31c01 100644 --- a/grpc.go +++ b/grpc.go @@ -81,7 +81,7 @@ type Server struct { stateHealth *atomic.Uint32 started bool registered bool - reflection bool + // reflection bool } func newServer(opts ...server.Option) *Server { diff --git a/reflection_test.go b/reflection_test.go index c769c7b..4a2780f 100644 --- a/reflection_test.go +++ b/reflection_test.go @@ -50,6 +50,7 @@ func (r *reflector) RangeExtensionsByMessage(message protoreflect.FullName, f fu } func TestReflector(t *testing.T) { + t.Skip() srv := NewServer(Reflection(&reflector{}), server.Address(":12345")) if err := srv.Init(); err != nil { t.Fatal(err) diff --git a/request.go b/request.go index 8ed32a9..86260be 100644 --- a/request.go +++ b/request.go @@ -1,8 +1,6 @@ package grpc import ( - "io" - "go.unistack.org/micro/v3/codec" "go.unistack.org/micro/v3/metadata" "go.unistack.org/micro/v3/server" @@ -11,7 +9,6 @@ import ( var _ server.Request = &rpcRequest{} type rpcRequest struct { - rw io.ReadWriter payload interface{} codec codec.Codec header metadata.Metadata diff --git a/response.go b/response.go index 3ba61b3..b1ad9b7 100644 --- a/response.go +++ b/response.go @@ -1,8 +1,6 @@ package grpc import ( - "io" - "go.unistack.org/micro/v3/codec" "go.unistack.org/micro/v3/metadata" "go.unistack.org/micro/v3/server" @@ -11,7 +9,6 @@ import ( var _ server.Response = &rpcResponse{} type rpcResponse struct { - rw io.ReadWriter header metadata.Metadata codec codec.Codec }