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