X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FFcpDialog.java;h=f218610bf33cb52bbd020675520a655ff4ecb7b4;hb=cd753d3f782e0024fd3edaa97b40f8e86bc3a8b3;hp=5be102c5b91ad0b92fdc813f9971e07c2b640c72;hpb=be6c1651ce3c53daa254fb2dbce9221450d381e8;p=jFCPlib.git diff --git a/src/main/java/net/pterodactylus/fcp/quelaton/FcpDialog.java b/src/main/java/net/pterodactylus/fcp/quelaton/FcpDialog.java index 5be102c..f218610 100644 --- a/src/main/java/net/pterodactylus/fcp/quelaton/FcpDialog.java +++ b/src/main/java/net/pterodactylus/fcp/quelaton/FcpDialog.java @@ -46,6 +46,7 @@ import net.pterodactylus.fcp.SSKKeypair; import net.pterodactylus.fcp.SentFeed; import net.pterodactylus.fcp.SimpleProgress; import net.pterodactylus.fcp.StartedCompression; +import net.pterodactylus.fcp.SubscribedUSK; import net.pterodactylus.fcp.SubscribedUSKUpdate; import net.pterodactylus.fcp.TestDDAComplete; import net.pterodactylus.fcp.TestDDAReply; @@ -356,6 +357,13 @@ public abstract class FcpDialog implements AutoCloseable, FcpListener { protected void consumePersistentRequestRemoved(PersistentRequestRemoved persistentRequestRemoved) { } @Override + public final void receivedSubscribedUSK(FcpConnection fcpConnection, SubscribedUSK subscribedUSK) { + consume(this::consumeSubscribedUSK, subscribedUSK); + } + + protected void consumeSubscribedUSK(SubscribedUSK subscribedUSK) { } + + @Override public final void receivedSubscribedUSKUpdate(FcpConnection fcpConnection, SubscribedUSKUpdate subscribedUSKUpdate) { consume(this::consumeSubscribedUSKUpdate, subscribedUSKUpdate); }