Merge pull request #106 from unistack-org/cleanup

cleanup

grpc.go

@@ -55,7 +55,6 @@ type grpcServer struct {
 	rpc         *rServer
 	opts        server.Options
 	sync.RWMutex
-	init       bool
 	started    bool
 	registered bool
 	reflection bool
@@ -166,8 +165,6 @@ func (g *grpcServer) configure(opts ...server.Option) error {
 		return g.Start()
 	}
 
-	g.init = true
-
 	return nil
 }
 
@@ -587,7 +584,7 @@ func (g *grpcServer) Options() server.Options {
 }
 
 func (g *grpcServer) Init(opts ...server.Option) error {
-	if len(opts) == 0 && g.init {
+	if len(opts) == 0 {
 		return nil
 	}
 	return g.configure(opts...)

request.go

@@ -31,7 +31,6 @@ type rpcMessage struct {
 	header      metadata.Metadata
 	topic       string
 	contentType string
-	body        []byte
 }
 
 func (r *rpcRequest) ContentType() string {