LarsG
diff --git a/‎src/main/java/com/github/pgasync/PgProtocolStream.java
Lines changed: 5 additions & 5 deletions b/‎src/main/java/com/github/pgasync/PgProtocolStream.java
Lines changed: 5 additions & 5 deletions
diff --git a/‎src/test/java/com/github/pgasync/netty/NettyPgProtocolStream.java
Lines changed: 6 additions & 6 deletions b/‎src/test/java/com/github/pgasync/netty/NettyPgProtocolStream.java
Lines changed: 6 additions & 6 deletions
@@ -145,7 +145,7 @@ public Runnable subscribe(String channel, Consumer<String> onNotification) {
         });
     }
 
-    protected void respondWithException(Throwable th) {
+    protected void gotException(Throwable th) {
         onColumns = null;
         onRow = null;
         onAffected = null;
@@ -157,7 +157,7 @@ protected void respondWithException(Throwable th) {
         }
     }
 
-    protected void respondWithMessage(Message message) {
+    protected void gotMessage(Message message) {
         if (message instanceof NotificationResponse) {
             publish((NotificationResponse) message);
         } else if (message == BIndicators.BIND_COMPLETE) {
@@ -174,7 +174,7 @@ protected void respondWithMessage(Message message) {
             if (seenReadyForQuery) {
                 readyForQueryPendingMessage = message;
             } else {
-                respondWithException(toSqlException((ErrorResponse) message));
+                gotException(toSqlException((ErrorResponse) message));
             }
         } else if (message instanceof CommandComplete) {
             if (isSimpleQueryInProgress()) {
@@ -195,7 +195,7 @@ protected void respondWithMessage(Message message) {
         } else if (message == ReadyForQuery.INSTANCE) {
             seenReadyForQuery = true;
             if (readyForQueryPendingMessage instanceof ErrorResponse) {
-                respondWithException(toSqlException((ErrorResponse) readyForQueryPendingMessage));
+                gotException(toSqlException((ErrorResponse) readyForQueryPendingMessage));
             } else {
                 onColumns = null;
                 onRow = null;
@@ -229,7 +229,7 @@ protected CompletableFuture<Message> offerRoundTrip(Runnable requestAction, bool
                 try {
                     requestAction.run();
                 } catch (Throwable th) {
-                    respondWithException(th);
+                    gotException(th);
                 }
             } else {
                 futuresExecutor.execute(() -> uponResponse.completeExceptionally(new IllegalStateException("Postgres messages stream simultaneous use detected")));
 
@@ -55,7 +55,7 @@ public class NettyPgProtocolStream extends PgProtocolStream {
 
     private final GenericFutureListener<Future<? super Object>> outboundErrorListener = written -> {
         if (!written.isSuccess()) {
-            respondWithException(written.cause());
+            gotException(written.cause());
         }
     };
 
@@ -162,23 +162,23 @@ private ChannelHandler newProtocolHandler() {
             public void channelActive(ChannelHandlerContext context) {
                 NettyPgProtocolStream.this.ctx = context;
                 if (useSsl) {
-                    respondWithMessage(SSLRequest.INSTANCE);
+                    gotMessage(SSLRequest.INSTANCE);
                 } else {
-                    respondWithMessage(startupWith);
+                    gotMessage(startupWith);
                 }
             }
 
             @Override
             public void userEventTriggered(ChannelHandlerContext context, Object evt) {
                 if (evt instanceof SslHandshakeCompletionEvent && ((SslHandshakeCompletionEvent) evt).isSuccess()) {
-                    respondWithMessage(SSLHandshake.INSTANCE);
+                    gotMessage(SSLHandshake.INSTANCE);
                 }
             }
 
             @Override
             public void channelRead(ChannelHandlerContext context, Object message) {
                 if (message instanceof Message) {
-                    respondWithMessage((Message) message);
+                    gotMessage((Message) message);
                 }
             }
 
@@ -189,7 +189,7 @@ public void channelInactive(ChannelHandlerContext context) {
 
             @Override
             public void exceptionCaught(ChannelHandlerContext context, Throwable cause) {
-                respondWithException(cause);
+                gotException(cause);
             }
         };
     }
Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ public class NettyPgProtocolStream extends PgProtocolStream {`
`55`	`55`
`56`	`56`	`private final GenericFutureListener<Future<? super Object>> outboundErrorListener = written -> {`
`57`	`57`	`if (!written.isSuccess()) {`
`58`		`- respondWithException(written.cause());`
	`58`	`+ gotException(written.cause());`
`59`	`59`	`}`
`60`	`60`	`};`
`61`	`61`
`@@ -162,23 +162,23 @@ private ChannelHandler newProtocolHandler() {`
`162`	`162`	`public void channelActive(ChannelHandlerContext context) {`
`163`	`163`	`NettyPgProtocolStream.this.ctx = context;`
`164`	`164`	`if (useSsl) {`
`165`		`- respondWithMessage(SSLRequest.INSTANCE);`
	`165`	`+ gotMessage(SSLRequest.INSTANCE);`
`166`	`166`	`} else {`
`167`		`- respondWithMessage(startupWith);`
	`167`	`+ gotMessage(startupWith);`
`168`	`168`	`}`
`169`	`169`	`}`
`170`	`170`
`171`	`171`	`@Override`
`172`	`172`	`public void userEventTriggered(ChannelHandlerContext context, Object evt) {`
`173`	`173`	`if (evt instanceof SslHandshakeCompletionEvent && ((SslHandshakeCompletionEvent) evt).isSuccess()) {`
`174`		`- respondWithMessage(SSLHandshake.INSTANCE);`
	`174`	`+ gotMessage(SSLHandshake.INSTANCE);`
`175`	`175`	`}`
`176`	`176`	`}`
`177`	`177`
`178`	`178`	`@Override`
`179`	`179`	`public void channelRead(ChannelHandlerContext context, Object message) {`
`180`	`180`	`if (message instanceof Message) {`
`181`		`- respondWithMessage((Message) message);`
	`181`	`+ gotMessage((Message) message);`
`182`	`182`	`}`
`183`	`183`	`}`
`184`	`184`
`@@ -189,7 +189,7 @@ public void channelInactive(ChannelHandlerContext context) {`
`189`	`189`
`190`	`190`	`@Override`
`191`	`191`	`public void exceptionCaught(ChannelHandlerContext context, Throwable cause) {`
`192`		`- respondWithException(cause);`
	`192`	`+ gotException(cause);`
`193`	`193`	`}`
`194`	`194`	`};`
`195`	`195`	`}`