Emit NoticeResponse through the message stream.

We now pass-thru NoticeResponse so that notices can be consumed as Result.Message.

[resolves #570]

Signed-off-by: Mark Paluch <[email protected]>

Author: mp911de

src/main/java/io/r2dbc/postgresql/client/ReactorNettyClient.java

@@ -268,9 +268,7 @@ private boolean consumeMessage(BackendMessage message) {
         }
 
         if (message.getClass() == NoticeResponse.class) {
-
             this.settings.getNoticeLogLevel().log(logger, () -> this.context.getMessage(String.format("Notice: %s", toString(((NoticeResponse) message).getFields()))));
-            return true;
         }
 
         if (message.getClass() == BackendKeyData.class) {

src/test/java/io/r2dbc/postgresql/SegmentIntegrationTests.java

@@ -0,0 +1,46 @@
+/*
+ * Copyright 2023 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.r2dbc.postgresql;
+
+import io.r2dbc.spi.Result;
+import org.junit.jupiter.api.Test;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+
+/**
+ * Integration tests {@link Result.Segment}.
+ */
+final class SegmentIntegrationTests extends AbstractIntegrationTests {
+
+    @Test
+    void shouldConsumeNotice() {
+
+        this.connection.createStatement("DO language plpgsql $$\n" +
+                "BEGIN\n" +
+                "  RAISE NOTICE 'hello, world!';\n" +
+                "END\n" +
+                "$$;").execute().flatMap(it -> it.flatMap(segment -> {
+                if (segment instanceof Result.Message) {
+                    return Mono.just(((Result.Message) segment).message());
+                }
+                return Mono.empty();
+            })).as(StepVerifier::create)
+            .expectNext("hello, world!")
+            .verifyComplete();
+    }
+
+}