fixup rpc CloseSend method #76
							
								
								
									
										2
									
								
								util.go
									
									
									
									
									
								
							
							
						
						
									
										2
									
								
								util.go
									
									
									
									
									
								
							| @@ -613,7 +613,7 @@ func (g *Generator) generateServiceClientStreamInterface(gfile *protogen.Generat | |||||||
| 		gfile.P("RecvMsg(msg interface{}) error") | 		gfile.P("RecvMsg(msg interface{}) error") | ||||||
| 		if method.Desc.IsStreamingClient() && !method.Desc.IsStreamingServer() { | 		if method.Desc.IsStreamingClient() && !method.Desc.IsStreamingServer() { | ||||||
| 			gfile.P("CloseAndRecv() (*", gfile.QualifiedGoIdent(method.Output.GoIdent), ", error)") | 			gfile.P("CloseAndRecv() (*", gfile.QualifiedGoIdent(method.Output.GoIdent), ", error)") | ||||||
| 			gfile.P("CloseSend() () error") | 			gfile.P("CloseSend() error") | ||||||
| 		} | 		} | ||||||
| 		gfile.P("Close() error") | 		gfile.P("Close() error") | ||||||
| 		if method.Desc.IsStreamingClient() { | 		if method.Desc.IsStreamingClient() { | ||||||
|   | |||||||
| @@ -21,5 +21,5 @@ var ( | |||||||
| 	grpcPackage            = protogen.GoImportPath("google.golang.org/grpc") | 	grpcPackage            = protogen.GoImportPath("google.golang.org/grpc") | ||||||
| 	timePackage            = protogen.GoImportPath("time") | 	timePackage            = protogen.GoImportPath("time") | ||||||
| 	deprecationComment     = "// Deprecated: Do not use." | 	deprecationComment     = "// Deprecated: Do not use." | ||||||
| 	versionComment         = "v4.0.0" | 	versionComment         = "v4.0.1" | ||||||
| ) | ) | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user