@Test
void shouldFlushOnRunRx()
{

    // Given
    Connection connection = connectionMock( BoltProtocolV4.INSTANCE );
    UnmanagedTransaction tx = beginTx( connection );
    setupSuccessfulRunRx( connection );
    // When
    await( tx.runRx( new Query( "RETURN 1" ) ) );
    // Then
    verifyRunRx( connection, "RETURN 1" );
}