Restore Session.reset as a private API

driver/src/main/java/org/neo4j/driver/internal/InternalSession.java

@@ -140,6 +140,13 @@ public Set<Bookmark> lastBookmarks() {
         return session.lastBookmarks();
     }
 
+    // Private API
+    public void reset() {
+        Futures.blockingGet(
+                session.resetAsync(),
+                () -> terminateConnectionOnThreadInterrupt("Thread interrupted while resetting the session"));
+    }
+
     private <T> T transaction(
             AccessMode mode, @SuppressWarnings("deprecation") TransactionWork<T> work, TransactionConfig config) {
         // use different code path compared to async so that work is executed in the caller thread

driver/src/main/java/org/neo4j/driver/internal/async/NetworkSession.java

@@ -164,6 +164,24 @@ public CompletionStage<UnmanagedTransaction> beginTransactionAsync(
         return newTransactionStage;
     }
 
+    // Private API
+    public CompletionStage<Void> resetAsync() {
+        return existingTransactionOrNull()
+                .thenAccept(tx -> {
+                    if (tx != null) {
+                        tx.markTerminated(null);
+                    }
+                })
+                .thenCompose(ignore -> connectionStage)
+                .thenCompose(connection -> {
+                    if (connection != null) {
+                        // there exists an active connection, send a RESET message over it
+                        return connection.reset();
+                    }
+                    return completedWithNull();
+                });
+    }
+
     public RetryLogic retryLogic() {
         return retryLogic;
     }

driver/src/main/java/org/neo4j/driver/internal/reactive/InternalRxSession.java

@@ -18,6 +18,8 @@
  */
 package org.neo4j.driver.internal.reactive;
 
+import static org.neo4j.driver.internal.reactive.RxUtils.createEmptyPublisher;
+
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 import org.neo4j.driver.AccessMode;
@@ -129,6 +131,10 @@ public Bookmark lastBookmark() {
         return InternalBookmark.from(session.lastBookmarks());
     }
 
+    public Publisher<Void> reset() {
+        return createEmptyPublisher(session::resetAsync);
+    }
+
     @Override
     public <T> Publisher<T> close() {
         return doClose();