Skip to content

Commit 1e692fc

Browse files
committed
Ensure sequential parameter collection.
ExtendedQueryPostgresqlStatement.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 26cbd92 commit 1e692fc

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,7 @@ private static void tryNextBinding(Iterator<Binding> iterator, EmitterProcessor<
235235
private static Mono<List<ByteBuf>> collectBindingParameters(Binding binding) {
236236

237237
return Flux.fromIterable(binding.getParameterValues())
238-
.flatMap(f -> {
238+
.concatMap(f -> {
239239
if (f == Parameter.NULL_VALUE) {
240240
return Flux.just(Bind.NULL_VALUE);
241241
} else {

0 commit comments

Comments
 (0)