fix: cancel is called when testing with the GNS.

Author: ArjanSchouten

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

@@ -23,6 +23,7 @@
 import io.r2dbc.postgresql.message.backend.BackendMessage;
 import io.r2dbc.postgresql.message.backend.CommandComplete;
 import io.r2dbc.postgresql.message.backend.CopyInResponse;
+import io.r2dbc.postgresql.message.backend.ErrorResponse;
 import io.r2dbc.postgresql.message.backend.ReadyForQuery;
 import io.r2dbc.postgresql.message.frontend.CopyData;
 import io.r2dbc.postgresql.message.frontend.CopyDone;
@@ -67,9 +68,7 @@ private Mono<Long> copyIn(String sql, Flux<FrontendMessage> frontendMessages) {
 
         return startCopy(sql)
             .concatWith(backendMessages)
-            .doOnCancel(() -> {
-                sendCopyFail("Cancelled");
-            })
+            .doOnCancel(() -> sendCopyFail("Cancelled"))
             .as(messages -> toResult(context, messages, ExceptionFactory.INSTANCE).getRowsUpdated());
     }
 
@@ -87,7 +86,7 @@ private Flux<BackendMessage> startCopy(String sql) {
     }
 
     private void sendCopyFail(String message) {
-        context.getClient().exchange(m -> m instanceof CommandComplete, Mono.just(new CopyFail("Copy operation failed: " + message)))
+        context.getClient().exchange(m -> m instanceof CommandComplete || m instanceof ErrorResponse, Mono.just(new CopyFail("Copy operation failed: " + message)))
             .subscribe();
     }