NetworkSession { public CompletionStage<RxResultCursor> runRx(Query query, TransactionConfig config ) { CompletionStage<RxResultCursor> newResultCursorStage = buildResultCursorFactory(query, config, true ).thenCompose( ResultCursorFactory::rxResult ); resultCursorStage = newResultCursorStage.exceptionally( error -> null ); return newResultCursorStage; } NetworkSession( ConnectionProvider connectionProvider, RetryLogic retryLogic, DatabaseName databaseName, AccessMode mode,
            BookmarkHolder bookmarkHolder, long fetchSize, Logging logging ); CompletionStage<ResultCursor> runAsync(Query query, TransactionConfig config, boolean waitForRunResponse ); CompletionStage<RxResultCursor> runRx(Query query, TransactionConfig config ); CompletionStage<UnmanagedTransaction> beginTransactionAsync( TransactionConfig config ); CompletionStage<UnmanagedTransaction> beginTransactionAsync( AccessMode mode, TransactionConfig config ); CompletionStage<Void> resetAsync(); RetryLogic retryLogic(); Bookmark lastBookmark(); CompletionStage<Void> releaseConnectionAsync(); CompletionStage<Connection> connectionAsync(); boolean isOpen(); CompletionStage<Void> closeAsync();  }
@Test void shouldFlushOnRunRx() { setupSuccessfulRunRx( connection ); await( session.runRx( new Query( "RETURN 1" ), TransactionConfig.empty() ) ); verifyRunRx( connection, "RETURN 1" ); }