X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FReloadPluginCommandImpl.java;h=7e53055025993e7e4c92bf8de9ea9c7a77018a74;hb=c7b30c245806a4a67d2e924d6d4e2a9e97916c5b;hp=a05963c876a3d156e163e443bc6631df67770326;hpb=7a3be5ca037785f4f1acb225381578db12d15eb1;p=jFCPlib.git diff --git a/src/main/java/net/pterodactylus/fcp/quelaton/ReloadPluginCommandImpl.java b/src/main/java/net/pterodactylus/fcp/quelaton/ReloadPluginCommandImpl.java index a05963c..7e53055 100644 --- a/src/main/java/net/pterodactylus/fcp/quelaton/ReloadPluginCommandImpl.java +++ b/src/main/java/net/pterodactylus/fcp/quelaton/ReloadPluginCommandImpl.java @@ -4,8 +4,6 @@ import java.io.IOException; import java.util.Optional; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; -import java.util.concurrent.atomic.AtomicBoolean; -import java.util.concurrent.atomic.AtomicReference; import java.util.function.Supplier; import net.pterodactylus.fcp.PluginInfo; @@ -69,32 +67,18 @@ public class ReloadPluginCommandImpl implements ReloadPluginCommand { private class ReloadPluginDialog extends FcpDialog> { - private final AtomicBoolean finished = new AtomicBoolean(); - private final AtomicReference pluginInfo = new AtomicReference<>(); - public ReloadPluginDialog() throws IOException { - super(threadPool, connectionSupplier.get()); - } - - @Override - protected boolean isFinished() { - return finished.get(); - } - - @Override - protected Optional getResult() { - return Optional.ofNullable(pluginInfo.get()); + super(threadPool, connectionSupplier.get(), Optional.empty()); } @Override protected void consumePluginInfo(PluginInfo pluginInfo) { - this.pluginInfo.set(pluginInfo); - finished.set(true); + setResult(Optional.ofNullable(pluginInfo)); } @Override protected void consumeProtocolError(ProtocolError protocolError) { - finished.set(true); + finish(); } }