@Test
void shouldInitCursorFutureWithFailedCursor()
{

    // Given
    RuntimeException error = new RuntimeException( "Failed to obtain cursor probably due to connection problem" );
    InternalRxResult rxResult = newRxResult( error );
    // When
    CompletableFuture<RxResultCursor> cursorFuture = rxResult.initCursorFuture().toCompletableFuture();
    // Then
    assertTrue( cursorFuture.isDone() );
    RuntimeException actualError = assertThrows( RuntimeException.class, () -> Futures.getNow( cursorFuture ) );
    assertThat( actualError.getCause(), equalTo( error ) );
}