X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FAddPeerCommandImpl.java;h=4fab83c089a1eece7a8df4fb0c48520fe8ee9dae;hb=90abd71ef157f31b3330d0d51664e3d14c889ccf;hp=a54f1666a926ab4dd2eb567e094c9d80823b9d67;hpb=e591c6488b692e3dfcf2efd1905d399f39c6067f;p=jFCPlib.git diff --git a/src/main/java/net/pterodactylus/fcp/quelaton/AddPeerCommandImpl.java b/src/main/java/net/pterodactylus/fcp/quelaton/AddPeerCommandImpl.java index a54f166..4fab83c 100644 --- a/src/main/java/net/pterodactylus/fcp/quelaton/AddPeerCommandImpl.java +++ b/src/main/java/net/pterodactylus/fcp/quelaton/AddPeerCommandImpl.java @@ -55,10 +55,10 @@ public class AddPeerCommandImpl implements AddPeerCommand { } private ListenableFuture> execute() { - return threadPool.submit(this::executeSequence); + return threadPool.submit(this::executeDialog); } - private Optional executeSequence() throws IOException, ExecutionException, InterruptedException { + private Optional executeDialog() throws IOException, ExecutionException, InterruptedException { AddPeer addPeer; if (file.get() != null) { addPeer = new AddPeer(new RandomIdentifierGenerator().generate(), file.get().getPath()); @@ -67,17 +67,17 @@ public class AddPeerCommandImpl implements AddPeerCommand { } else { addPeer = new AddPeer(new RandomIdentifierGenerator().generate(), nodeRef.get()); } - try (AddPeerSequence addPeerSequence = new AddPeerSequence()) { - return addPeerSequence.send(addPeer).get(); + try (AddPeerDialog addPeerDialog = new AddPeerDialog()) { + return addPeerDialog.send(addPeer).get(); } } - private class AddPeerSequence extends FcpDialog> { + private class AddPeerDialog extends FcpDialog> { private final AtomicBoolean finished = new AtomicBoolean(); private final AtomicReference peer = new AtomicReference<>(); - public AddPeerSequence() throws IOException { + public AddPeerDialog() throws IOException { super(threadPool, connectionSupplier.get()); }