diff --git a/internal/rpc/msg/clear.go b/internal/rpc/msg/clear.go index 2b22ef513..7864dbe21 100644 --- 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 }