private ListenableFuture<Optional<Peer>> execute() {
return threadPool.submit(this::executeSequence);
}
private Optional<Peer> executeSequence() throws IOException, ExecutionException, InterruptedException {
private ListenableFuture<Optional<Peer>> execute() {
return threadPool.submit(this::executeSequence);
}
private Optional<Peer> executeSequence() throws IOException, ExecutionException, InterruptedException {