From 0c6589a630fb1b63f76f6c6133d196b9a445cd4c Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Tue, 26 Dec 2023 00:55:09 +0300 Subject: [PATCH] fix gen Signed-off-by: Vasiliy Tolstov --- util.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/util.go b/util.go index 52e358c..b7e11aa 100644 --- a/util.go +++ b/util.go @@ -572,7 +572,7 @@ func (g *Generator) generateClientFuncSignature(gfile *protogen.GeneratedFile, s if !method.Desc.IsStreamingClient() && !method.Desc.IsStreamingServer() { args = append(args, "*", gfile.QualifiedGoIdent(method.Output.GoIdent)) } else { - args = append(args, serviceName, "_", method.GoName, "Client") + args = append(args, gfile.QualifiedGoIdent(protogen.GoIdent{GoName: serviceName + "_" + method.GoName + "Client", GoImportPath: method.Output.GoIdent.GoImportPath})) } args = append(args, ", error) {") gfile.P(args...) @@ -657,7 +657,7 @@ func (g *Generator) generateServiceServerStreamInterface(gfile *protogen.Generat gfile.P("RecvMsg(msg interface{}) error") if method.Desc.IsStreamingClient() && !method.Desc.IsStreamingServer() { gfile.P("SendAndClose(msg *", gfile.QualifiedGoIdent(method.Output.GoIdent), ") error") - gfile.P("CloseSend() error") + // gfile.P("CloseSend() error") } gfile.P("Close() error") if method.Desc.IsStreamingClient() {