I would like to know how to use/control the Quarkus reactive Redis client with pipelining (ReactiveRedisDataSource). I understand the client does pipelining by default, but how can we control how many commands are pipelined before the request is sent? For example:
@Inject
ReactiveRedisDataSource reactiveDS;
// some code below ...
reactiveDS.list(String.class).lpush("myList", "randomString")
.chain(() -> reactiveDS.hash(String.class).hset("myKey", "field1", "randomValue"))
Does the code above pipelines those 2 commands? If not then how can I pipeline? If yes, how can I control how many messages can I enqueue before sending and how can I get the array response?