diff --git a/v2/routes.go b/v2/routes.go index f1c4d4e..6ba577a 100644 --- a/v2/routes.go +++ b/v2/routes.go @@ -365,6 +365,11 @@ func (s *Server) deleteAllSubscriptions(w http.ResponseWriter, _ *http.Request) respondWithError(w, err.Error()) return } + // empty the store in memory + if err = s.pubSubAPI.DeleteAllSubscriptions(); err != nil { + respondWithError(w, err.Error()) + return + } respondWithStatusCode(w, http.StatusNoContent, "") }