поток реактивной записи vert.x в aws sdk v2

Question

Я хочу написать код с vert.x, который считывает строки из файла (разделенного \ n), анализирует их, а затем записывает их в Dynamodb - я использую Java aws -sdk v2.

Я хочу контролировать скорость записи в динамо-машину, поэтому я подумал о реализации противодавления с помощью модуля реактивных потоков vert.x (ReactiveReadStream и ReactiveWriteStream)

Я не уверен, как решить эту проблему с помощью aws java sdk.

как я могу проанализировать строки с помощью парсера записи и устранить разрыв между awssdk и ReactiveWriteStream?

fileSystem.open("path/to/file", new OpenOptions(),asyncFileResult -> handleOpenAsyncFileResult(asyncFileResult));


    private void handleOpenAsyncFileResult(AsyncResult<AsyncFile> asyncFileAsyncResult) {
    if(asyncFileAsyncResult.succeeded()) {
        AsyncFile asyncFile = asyncFileAsyncResult.result();

        ReactiveReadStream<Buffer> rrs = ReactiveReadStream.readStream();

        RecordParser recordParser1 = RecordParser.newDelimited("\n",rrs);


        asyncFile.handler(recordParser1).endHandler(new Handler<Void>() {
            @Override
            public void handle(Void event) {
                logger.info("finished ");
            }
        });

    }

}