X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=core%2Fstream.go;h=2f639b01e8912d14a1aebf10d4ebd41fcf714b16;hb=385ccc0d8ba929f39881efb7784bfb0921044ae8;hp=363cc9f944d16640115a670a295313712e02469d;hpb=a5739cb7160349f96c428995049ff61411689ea0;p=govpp.git diff --git a/core/stream.go b/core/stream.go index 363cc9f..2f639b0 100644 --- a/core/stream.go +++ b/core/stream.go @@ -70,6 +70,7 @@ func (c *Connection) Invoke(ctx context.Context, req api.Message, reply api.Mess if err != nil { return err } + defer func() { _ = stream.Close() }() if err := stream.SendMsg(req); err != nil { return err }