2
grpc.go
2
grpc.go
@@ -178,7 +178,7 @@ func (g *grpcServer) handler(srv interface{}, stream grpc.ServerStream) error {
|
|||||||
|
|
||||||
fullMethod, ok := grpc.MethodFromServerStream(stream)
|
fullMethod, ok := grpc.MethodFromServerStream(stream)
|
||||||
if !ok {
|
if !ok {
|
||||||
return grpc.Errorf(codes.Internal, "method does not exist in context")
|
return status.Errorf(codes.Internal, "method does not exist in context")
|
||||||
}
|
}
|
||||||
|
|
||||||
serviceName, methodName, err := mgrpc.ServiceMethod(fullMethod)
|
serviceName, methodName, err := mgrpc.ServiceMethod(fullMethod)
|
||||||
|
Reference in New Issue
Block a user