БУНТ ДЛЯ КОДИРОВАНИЯ BASE64 — лучшее решение? ⇐ JAVA

[Anonymous]

Я хочу прочитать большую строку base64 и декодировать ее в строку для сохранения в файле (возможно, в файле в будущем). Я хочу читать по 4 байта за раз (поскольку закодировано в Base64), но лучше всего в многопоточном режиме. Это правильный код или неправильный? Как? Спасибо!
Optional result1 = convertFileToBase64InStreamingFashion2("c:/temp/prova.txt").collect().asList()
.await().indefinitely()
.stream().reduce((acc, el) -> acc.concat(el));
logger.info(result1.get());

public Multi convertFileToBase64InStreamingFashion2(String path ) throws IOException {
logger.info("start thread " + Thread.currentThread());
AtomicInteger i = new AtomicInteger(1);
return vertx.fileSystem().open(path, new OpenOptions().setRead(true))
.log()
.onItem().invoke(
x-> x.setReadBufferSize(3))
.onItem().transformToMulti(AsyncFile::toMulti)
.log()
.emitOn(managedExecutor)
.onItem().transform(b ->
new Base64().encodeAsString(b.getBytes()))
.log();

}

log() печатает:
2024-04-17 22:57:01,638 INFO  [org.acm.GreetingService] (Quarkus Main Thread) start thread Thread[Quarkus Main Thread,5,build group]
2024-04-17 22:57:01,639 INFO  [io.qua.mut.run.MutinyInfrastructure] (Quarkus Main Thread) Uni.AsyncResultUni.0 | onSubscribe()
2024-04-17 22:57:01,640 INFO  [io.qua.mut.run.MutinyInfrastructure] (Quarkus Main Thread) Multi.UniOnItemTransformToMulti.0 | onSubscribe()
2024-04-17 22:57:01,640 INFO  [io.qua.mut.run.MutinyInfrastructure] (Quarkus Main Thread) Multi.MultiMapOp.0 | onSubscribe()
2024-04-17 22:57:01,640 INFO  [io.qua.mut.run.MutinyInfrastructure] (Quarkus Main Thread) Multi.MultiMapOp.0 | request(9223372036854775807)
2024-04-17 22:57:01,640 INFO  [io.qua.mut.run.MutinyInfrastructure] (Quarkus Main Thread) Multi.UniOnItemTransformToMulti.0 | request(16)
2024-04-17 22:57:01,641 INFO  [io.qua.mut.run.MutinyInfrastructure] (vert.x-eventloop-thread-4) Uni.AsyncResultUni.0 | onItem(io.vertx.core.file.impl.AsyncFileImpl@45a0f69c)
2024-04-17 22:57:01,642 INFO  [io.qua.mut.run.MutinyInfrastructure] (vert.x-eventloop-thread-4) Multi.UniOnItemTransformToMulti.0 | onItem(#du)
2024-04-17 22:57:01,642 INFO  [io.qua.mut.run.MutinyInfrastructure] (executor-thread-1) Multi.MultiMapOp.0 | onItem(I2R1)

..

2024-04-17 22:57:10,150 INFO  [io.qua.mut.run.MutinyInfrastructure] (executor-thread-2) Multi.UniOnItemTransformToMulti.0 | request(16)
2024-04-17 22:57:10,152 INFO  [io.qua.mut.run.MutinyInfrastructure] (vert.x-eventloop-thread-4) Multi.UniOnItemTransformToMulti.0 | onCompletion()
2024-04-17 22:57:10,152 INFO  [io.qua.mut.run.MutinyInfrastructure] (executor-thread-2) Multi.MultiMapOp.0 | onCompletion()


Подробнее здесь: https://stackoverflow.com/questions/783 ... r-solution