CompletableFuture<ConvertResult> future = client.convertBytesAsync(
    data, "report.pdf", ConvertOptions.defaults()
);

future
    .thenAccept(result -> {
        if (result instanceof ConvertResult.Markdown md) {
            System.out.println(md.markdown());
        }
    })
    .exceptionally(err -> {
        Throwable cause = err.getCause() != null ? err.getCause() : err;
        if (cause instanceof MarkpdfException.RateLimitException) {
            System.out.println("Rate limited, retry later");
        } else {
            cause.printStackTrace();
        }
        return null;
    });

List<Path> pdfs = List.of(Path.of("a.pdf"), Path.of("b.pdf"), Path.of("c.pdf"));

List<CompletableFuture<ConvertResult>> futures = pdfs.stream()
    .map(path -> client.convertBytesAsync(
        readAllBytesUnchecked(path), path.getFileName().toString(), ConvertOptions.defaults()))
    .toList();

CompletableFuture<Void> all = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]));

all.join(); // espera a que todas terminen
List<ConvertResult> results = futures.stream().map(CompletableFuture::join).toList();

// SDK waits and polls automatically (blocking)
ConvertResult result = client.convertFile(Path.of("report.pdf"), ConvertOptions.defaults());

ConvertOptions options = ConvertOptions.builder().autoPoll(false).build();
ConvertResult result = client.convertFile(Path.of("report.pdf"), options);

if (result instanceof ConvertResult.Queued queued) {
    System.out.println("En cola: " + queued.job().jobId());

    Job finalJob = client.waitForJob(
        queued.job().jobId(),
        Duration.ofSeconds(5),
        Duration.ofMinutes(10)
    );

    if (finalJob.status() == JobStatus.COMPLETED) {
        String markdown = (String) finalJob.body();
    } else {
        throw new RuntimeException(finalJob.error());
    }
}