@Test
void shouldNotFailRxResultEvenWhenRunFailed() throws Throwable
{

    // Given
    Connection connection = mock( Connection.class );
    Throwable error = new RuntimeException( "Hi there" );
    ResultCursorFactory cursorFactory = newResultCursorFactory( connection, completedFuture( error ), false );
    // When
    CompletionStage<RxResultCursor> cursorFuture = cursorFactory.rxResult();
    // Then
    verifyRxRunCompleted( connection, cursorFuture );
}