@Test
void shouldErrorWhenFailedObtainKeys()
{

    // Given
    RuntimeException error = new RuntimeException( "Failed to obtain cursor" );
    InternalRxResult rxResult = newRxResult( error );
    // When & Then
    StepVerifier.create( Flux.from( rxResult.keys() ) )
            .expectErrorMatches( isEqual( error ) )
            .verify();
}