diff --git a/src/main/java/me/kavin/piped/utils/PubSubHelper.java b/src/main/java/me/kavin/piped/utils/PubSubHelper.java index 7b07a38..23976b7 100644 --- a/src/main/java/me/kavin/piped/utils/PubSubHelper.java +++ b/src/main/java/me/kavin/piped/utils/PubSubHelper.java @@ -48,6 +48,10 @@ public class PubSubHelper { .thenAccept(resp -> { if (resp.status() != 202) System.out.println("Failed to subscribe: " + resp.status() + "\n" + new String(resp.body())); + }) + .exceptionally(e -> { + ExceptionHandler.handle((Exception) e); + return null; }); } }