unistack-org/micro
4
0
Fork 3
Code Issues 18 Pull Requests 1 Actions Packages Projects Releases 265 Wiki Activity

generate SendAndClose() and CloseAndRecv() on streams. #7

Merged
itzmanish merged 1 commits from protoc-gen-micro-fix into master 2020-11-07 15:53:01 +03:00
Conversation 2 Commits 1 Files Changed 1 +32
1 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 2141e9631c - Show all commits

32
cmd/protoc-gen-micro/plugin/micro/micro.go
View File

@ -378,6 +378,11 @@ func (g *micro) generateClientMethod(reqServ, servName, serviceDescVar string, m
g.P("Context() context.Context") g.P("Context() context.Context")
g.P("SendMsg(interface{}) error") g.P("SendMsg(interface{}) error")
g.P("RecvMsg(interface{}) error") g.P("RecvMsg(interface{}) error")
if genSend && !genRecv {
// client streaming, the server will send a response upon close
g.P("CloseAndRecv() (*", outType, ", error)")
}
g.P("Close() error") g.P("Close() error")
if genSend { if genSend {
@ -394,6 +399,18 @@ func (g *micro) generateClientMethod(reqServ, servName, serviceDescVar string, m
g.P("}") g.P("}")
g.P() g.P()
if genSend && !genRecv {
// client streaming, the server will send a response upon close
g.P("func (x *", streamType, ") CloseAndRecv() (*", outType, ", error) {")
g.P("if err := x.stream.Close(); err != nil {")
g.P("return nil, err")
g.P("}")
g.P("r := new(", outType, ")")
g.P("err := x.RecvMsg(r)")
g.P("return r, err")
g.P("}")
g.P()
}
g.P("func (x *", streamType, ") Close() error {") g.P("func (x *", streamType, ") Close() error {")
g.P("return x.stream.Close()") g.P("return x.stream.Close()")
g.P("}") g.P("}")
@ -493,6 +510,10 @@ func (g *micro) generateServerMethod(servName string, method *pb.MethodDescripto
g.P("Context() context.Context") g.P("Context() context.Context")
g.P("SendMsg(interface{}) error") g.P("SendMsg(interface{}) error")
g.P("RecvMsg(interface{}) error") g.P("RecvMsg(interface{}) error")
if !genSend {
// client streaming, the server will send a response upon close
g.P("SendAndClose(*", outType, ") error")
}
g.P("Close() error") g.P("Close() error")
if genSend { if genSend {
@ -511,6 +532,17 @@ func (g *micro) generateServerMethod(servName string, method *pb.MethodDescripto
g.P("}") g.P("}")
g.P() g.P()
if !genSend {
// client streaming, the server will send a response upon close
g.P("func (x *", streamType, ") SendAndClose(in *", outType, ") error {")
g.P("if err := x.SendMsg(in); err != nil {")
g.P("return err")
g.P("}")
g.P("return x.stream.Close()")
g.P("}")
g.P()
}
// other types of rpc don't send a response when the stream closes
g.P("func (x *", streamType, ") Close() error {") g.P("func (x *", streamType, ") Close() error {")
g.P("return x.stream.Close()") g.P("return x.stream.Close()")
g.P("}") g.P("}")