Refactoring and fixes

[govpp.git] / binapi / memclnt / memclnt_rpc.ba.go

diff --git a/binapi/memclnt/memclnt_rpc.ba.go b/binapi/memclnt/memclnt_rpc.ba.go
index ef4a1a4..03d32ef 100644 (file)
--- a/binapi/memclnt/memclnt_rpc.ba.go
+++ b/binapi/memclnt/memclnt_rpc.ba.go
@@ -87,6 +87,10 @@ func (c *serviceClient) MemclntReadTimeout(ctx context.Context, in *MemclntReadT
        if err != nil {
                return err
        }
+       err = stream.Close()
+       if err != nil {
+               return err
+       }
        return nil
 }
 
@@ -99,6 +103,10 @@ func (c *serviceClient) MemclntRxThreadSuspend(ctx context.Context, in *MemclntR
        if err != nil {
                return err
        }
+       err = stream.Close()
+       if err != nil {
+               return err
+       }
        return nil
 }
 
@@ -120,6 +128,10 @@ func (c *serviceClient) RxThreadExit(ctx context.Context, in *RxThreadExit) erro
        if err != nil {
                return err
        }
+       err = stream.Close()
+       if err != nil {
+               return err
+       }
        return nil
 }
 
@@ -159,5 +171,9 @@ func (c *serviceClient) TracePluginMsgIds(ctx context.Context, in *TracePluginMs
        if err != nil {
                return err
        }
+       err = stream.Close()
+       if err != nil {
+               return err
+       }
        return nil
 }