diff --git a/src/main/java/me/kavin/piped/utils/ResponseHelper.java b/src/main/java/me/kavin/piped/utils/ResponseHelper.java index b0114ca..ba08663 100644 --- a/src/main/java/me/kavin/piped/utils/ResponseHelper.java +++ b/src/main/java/me/kavin/piped/utils/ResponseHelper.java @@ -789,8 +789,10 @@ public class ResponseHelper { if (user != null) { try (Session s = DatabaseSessionFactory.createSession()) { if (user.getSubscribed().contains(channelId)) { + Set subscribed = user.getSubscribed(); + subscribed.removeIf(sub -> sub.equals(channelId)); + user.setSubscribed(subscribed); - user.getSubscribed().removeIf(sub -> sub.equals(channelId)); s.update(user); s.getTransaction().begin(); s.getTransaction().commit();