我想用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 ");
            }
        });

    }

}