metadata is null

mariadb-corporation · Jan 5, 2023 · ce68aed · ce68aed
1 parent a17692a
commit ce68aed
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/mariadb/r2dbc/client/MariadbResult.java b/src/main/java/org/mariadb/r2dbc/client/MariadbResult.java
@@ -161,7 +161,7 @@ public <T> Flux<T> map(BiFunction<Row, RowMetadata, ? extends T> f) {
 
               ByteBuf buf = getLongTextEncoded(okPacket.getLastInsertId());
               org.mariadb.r2dbc.api.MariadbRow row = new MariadbRowText(buf, tmpMeta, factory);
-              sink.next(f.apply(row, meta.get()));
+              sink.next(f.apply(row, row.getMetadata()));
               ReferenceCountUtil.release(row);
             }
             return;