UnmanagedTransaction { public CompletionStage<RxResultCursor> runRx(Query query) { ensureCanRunQueries(); CompletionStage<RxResultCursor> cursorStage = protocol.runInUnmanagedTransaction( connection, query, this, false, fetchSize ).rxResult(); resultCursors.add( cursorStage ); return cursorStage; } UnmanagedTransaction(Connection connection, BookmarkHolder bookmarkHolder, long fetchSize ); CompletionStage<UnmanagedTransaction> beginAsync(Bookmark initialBookmark, TransactionConfig config ); CompletionStage<Void> closeAsync(); CompletionStage<Void> commitAsync(); CompletionStage<Void> rollbackAsync(); CompletionStage<ResultCursor> runAsync(Query query, boolean waitForRunResponse ); CompletionStage<RxResultCursor> runRx(Query query); boolean isOpen(); void markTerminated( Throwable cause ); Connection connection();  }
@Test void shouldFlushOnRunRx() { Connection connection = connectionMock( BoltProtocolV4.INSTANCE ); UnmanagedTransaction tx = beginTx( connection ); setupSuccessfulRunRx( connection ); await( tx.runRx( new Query( "RETURN 1" ) ) ); verifyRunRx( connection, "RETURN 1" ); }