update errgroup wait.

1 year ago · 33abddadb5
parent 07eb0cb387
commit 33abddadb5
1 changed files with 5 additions and 0 deletions
--- a/internal/rpc/msg/clear.go
+++ b/internal/rpc/msg/clear.go
@ -132,5 +132,10 @@ func (m *msgServer) DestructMsgs(ctx context.Context, req *msg.DestructMsgsReq)
 			return nil
 		})
 	}
+
+	if err := errg.Wait(); err != nil {
+		return nil, err
+	}
+
 	return nil, nil
 }