+ public ListPeersCommand includeMetadata() {
+ includeMetadata.set(true);
+ return this;
+ }
+
+ @Override
+ public ListPeersCommand includeVolatile() {
+ includeVolatile.set(true);
+ return this;
+ }
+
+ @Override
+ public ListenableFuture<Collection<Peer>> execute() {
+ return threadPool.submit(this::executeSequence);
+ }
+
+ private Collection<Peer> executeSequence() throws InterruptedException, ExecutionException, IOException {