Skip to content

Commit aacf383

Browse files
committed
Ensure sequential parameter collection.
PostgresqlStatement.collectBindingParameters(…) now uses concatMap to collect encoded parameter values instead of flatMap to ensure a consistent parameter ordering. [resolves #482] Signed-off-by: Mark Paluch <[email protected]>
1 parent 9afe70f commit aacf383

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/io/r2dbc/postgresql/PostgresqlStatement.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,7 @@ private static void tryNextBinding(Iterator<Binding> iterator, Sinks.Many<Bindin
266266
private static Mono<List<ByteBuf>> collectBindingParameters(Binding binding) {
267267

268268
return Flux.fromIterable(binding.getParameterValues())
269-
.flatMap(f -> {
269+
.concatMap(f -> {
270270
if (f == EncodedParameter.NULL_VALUE) {
271271
return Flux.just(Bind.NULL_VALUE);
272272
} else {

0 commit comments

Comments
 (0)