X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FListPeersCommandImpl.java;h=921c0faf9dcffeeaa594b596082e9ec6a00b2fd7;hb=54b77863a4a3d63a0298157a87afb09007b03fc4;hp=3d3baedbc0999257dce8a398098db70fafb3879d;hpb=b315e585ac78058d727eea98aca2ba9c7ed93c51;p=jFCPlib.git diff --git a/src/main/java/net/pterodactylus/fcp/quelaton/ListPeersCommandImpl.java b/src/main/java/net/pterodactylus/fcp/quelaton/ListPeersCommandImpl.java index 3d3baed..921c0fa 100644 --- a/src/main/java/net/pterodactylus/fcp/quelaton/ListPeersCommandImpl.java +++ b/src/main/java/net/pterodactylus/fcp/quelaton/ListPeersCommandImpl.java @@ -16,7 +16,7 @@ import com.google.common.util.concurrent.ListeningExecutorService; import com.google.common.util.concurrent.MoreExecutors; /** - * Default {@link ListPeersCommand} implementation based on {@link FcpReplySequence}. + * Default {@link ListPeersCommand} implementation based on {@link FcpDialog}. * * @author David ‘Bombe’ Roden */ @@ -52,17 +52,17 @@ public class ListPeersCommandImpl implements ListPeersCommand { private Collection executeSequence() throws InterruptedException, ExecutionException, IOException { String identifier = new RandomIdentifierGenerator().generate(); ListPeers listPeers = new ListPeers(identifier, includeMetadata.get(), includeVolatile.get()); - try (ListPeersReplySequence listPeersReplySequence = new ListPeersReplySequence()) { - return listPeersReplySequence.send(listPeers).get(); + try (ListPeersDialog listPeersDialog = new ListPeersDialog()) { + return listPeersDialog.send(listPeers).get(); } } - private class ListPeersReplySequence extends FcpReplySequence> { + private class ListPeersDialog extends FcpDialog> { private final Collection peers = new HashSet<>(); private final AtomicBoolean finished = new AtomicBoolean(false); - public ListPeersReplySequence() throws IOException { + public ListPeersDialog() throws IOException { super(threadPool, connectionSupplier.get()); }