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 {

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)

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

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
 }