5
									
								
								grpc.go
									
									
									
									
									
								
							
							
						
						
									
										5
									
								
								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...) | ||||
|   | ||||
| @@ -31,7 +31,6 @@ type rpcMessage struct { | ||||
| 	header      metadata.Metadata | ||||
| 	topic       string | ||||
| 	contentType string | ||||
| 	body        []byte | ||||
| } | ||||
|  | ||||
| func (r *rpcRequest) ContentType() string { | ||||
|   | ||||
		Reference in New Issue
	
	Block a user