FDio
diff --git a/Diff for: ‎binapi/graph/graph_rpc.ba.go
+1 b/Diff for: ‎binapi/graph/graph_rpc.ba.go
+1
diff --git a/Diff for: ‎binapi/interface/interface_rpc.ba.go
+1 b/Diff for: ‎binapi/interface/interface_rpc.ba.go
+1
diff --git a/Diff for: ‎binapi/ip/ip_rpc.ba.go
+1 b/Diff for: ‎binapi/ip/ip_rpc.ba.go
+1
diff --git a/Diff for: ‎binapi/ipfix_export/ipfix_export_rpc.ba.go
+1 b/Diff for: ‎binapi/ipfix_export/ipfix_export_rpc.ba.go
+1
diff --git a/Diff for: ‎binapi/lcp/lcp_rpc.ba.go
+1 b/Diff for: ‎binapi/lcp/lcp_rpc.ba.go
+1
diff --git a/Diff for: ‎binapi/map/map_rpc.ba.go
+1 b/Diff for: ‎binapi/map/map_rpc.ba.go
+1
diff --git a/Diff for: ‎binapi/mss_clamp/mss_clamp_rpc.ba.go
+1 b/Diff for: ‎binapi/mss_clamp/mss_clamp_rpc.ba.go
+1
diff --git a/Diff for: ‎binapi/nat44_ed/nat44_ed_rpc.ba.go
+1 b/Diff for: ‎binapi/nat44_ed/nat44_ed_rpc.ba.go
+1
diff --git a/Diff for: ‎binapi/nat44_ei/nat44_ei_rpc.ba.go
+1 b/Diff for: ‎binapi/nat44_ei/nat44_ei_rpc.ba.go
+1
diff --git a/Diff for: ‎binapi/pnat/pnat_rpc.ba.go
+2 b/Diff for: ‎binapi/pnat/pnat_rpc.ba.go
+2
diff --git a/Diff for: ‎binapi/tracedump/tracedump_rpc.ba.go
+1 b/Diff for: ‎binapi/tracedump/tracedump_rpc.ba.go
+1
diff --git a/Diff for: ‎binapigen/generate_rpc.go
+1 b/Diff for: ‎binapigen/generate_rpc.go
+1
@@ -170,6 +170,7 @@ func genService(g *GenFile, svc *Service) {
 			if msgReply != msgControlPingReply {
 				if retvalField := getRetvalField(msgReply); retvalField != nil {
 					g.P("if err := ", retvalFieldToErr(g, "m", retvalField), "; err != nil {")
+					g.P("	c.Stream.Close()")
 					if msgReply != msgControlPingReply {
 						g.P("	return nil, m, err")
 					} else {